Package org.apache.beam.runners.fnexecution.state

Interface StateRequestHandlers.MultimapSideInputHandler<K,V,W extends BoundedWindow>

All Superinterfaces:
StateRequestHandlers.SideInputHandler
Enclosing class:
StateRequestHandlers
@ThreadSafe public static interface StateRequestHandlers.MultimapSideInputHandler<K,V,W extends BoundedWindow> extends StateRequestHandlers.SideInputHandler
A handler for multimap side inputs.

Note that this handler is expected to be thread safe as it will be invoked concurrently.

  • Method Summary

    Modifier and Type
    Method
    Description
    Iterable<V>
    get(K key, W window)
    Returns an Iterable of values representing the side input for the given key and window.
    Iterable<K>
    get(W window)
    Returns an Iterable of keys representing the side input for the given window.
    Coder<K>
    keyCoder()
    Returns the Coder to use for the elements of the resulting keys iterable.
    Coder<V>
    valueCoder()
    Returns the Coder to use for the elements of the resulting values iterable.

  • Method Details

    • get

      Iterable<K> get(W window)
      Returns an Iterable of keys representing the side input for the given window.

      TODO: Add support for side input chunking and caching if a Reiterable is returned.

    • get

      Iterable<V> get(K key, W window)
      Returns an Iterable of values representing the side input for the given key and window.

      TODO: Add support for side input chunking and caching if a Reiterable is returned.

    • keyCoder

      Coder<K> keyCoder()
      Returns the Coder to use for the elements of the resulting keys iterable.

    • valueCoder

      Coder<V> valueCoder()
      Returns the Coder to use for the elements of the resulting values iterable.