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

Interface StateRequestHandlers.SideInputHandlerFactory

All Known Implementing Classes:

BatchSideInputHandlerFactory, StreamingSideInputHandlerFactory

Enclosing class:

StateRequestHandlers

@ThreadSafe
public static interface StateRequestHandlers.SideInputHandlerFactory

A factory which constructs StateRequestHandlers.MultimapSideInputHandlers.

Note that this factory should be thread safe because it will be invoked concurrently.

Method Summary

Modifier and Type	Method	Description
<V, W extends BoundedWindow> StateRequestHandlers.IterableSideInputHandler<V,W>	forIterableSideInput(String pTransformId, String sideInputId, Coder<V> elementCoder, Coder<W> windowCoder)	Returns an StateRequestHandlers.IterableSideInputHandler for the given pTransformId, sideInputId.
<K, V, W extends BoundedWindow> StateRequestHandlers.MultimapSideInputHandler<K,V,W>	forMultimapSideInput(String pTransformId, String sideInputId, KvCoder<K,V> elementCoder, Coder<W> windowCoder)	Returns a StateRequestHandlers.MultimapSideInputHandler for the given pTransformId, sideInputId.
static StateRequestHandlers.SideInputHandlerFactory	unsupported()	Throws a UnsupportedOperationException on the first access.

Method Details

forIterableSideInput

<V,
W extends BoundedWindow>
StateRequestHandlers.IterableSideInputHandler<V,W> forIterableSideInput(String pTransformId,
 String sideInputId,
 Coder<V> elementCoder,
 Coder<W> windowCoder)

Returns an StateRequestHandlers.IterableSideInputHandler for the given pTransformId, sideInputId. The supplied elementCoder and windowCoder should be used to encode/decode their respective values.

forMultimapSideInput

<K,
V,
W extends BoundedWindow>
StateRequestHandlers.MultimapSideInputHandler<K,V,W> forMultimapSideInput(String pTransformId,
 String sideInputId,
 KvCoder<K,V> elementCoder,
 Coder<W> windowCoder)

Returns a StateRequestHandlers.MultimapSideInputHandler for the given pTransformId, sideInputId. The supplied elementCoder and windowCoder should be used to encode/decode their respective values.

unsupported

static StateRequestHandlers.SideInputHandlerFactory unsupported()

Throws a UnsupportedOperationException on the first access.