org.apache.beam.runners.fnexecution.state

Interface StateRequestHandlers.SideInputHandler<V,W extends BoundedWindow>

Enclosing class:

StateRequestHandlers

@ThreadSafe
public static interface StateRequestHandlers.SideInputHandler<V,W extends BoundedWindow>

A handler for side inputs.

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

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<V>	get(byte[] key, W window) Returns an Iterable of values representing the side input for the given key and window.
Coder<V>	resultCoder() Returns the Coder to use for the elements of the resulting values iterable.

Method Detail

get

java.lang.Iterable<V> get(byte[] key,
                          W window)

Returns an Iterable of values representing the side input for the given key and window.

The key is interpreted according to the access pattern of side input.

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

resultCoder

Coder<V> resultCoder()

Returns the Coder to use for the elements of the resulting values iterable.