@ThreadSafe public static interface StateRequestHandlers.MultimapSideInputHandler<K,V,W extends BoundedWindow> extends StateRequestHandlers.SideInputHandler
Note that this handler is expected to be thread safe as it will be invoked concurrently.
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<V> |
get(K key,
W window)
Returns an
Iterable of values representing the side input for the given key and
window. |
java.lang.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. |
java.lang.Iterable<K> get(W window)
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.
java.lang.Iterable<V> get(K key, W window)
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.
Coder<K> keyCoder()
Coder
to use for the elements of the resulting keys iterable.