org.apache.beam.runners.fnexecution.state

Interface StateRequestHandlers.MultimapSideInputHandlerFactory

Enclosing class:

StateRequestHandlers

@ThreadSafe
public static interface StateRequestHandlers.MultimapSideInputHandlerFactory

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 and Description
<K,V,W extends BoundedWindow> StateRequestHandlers.MultimapSideInputHandler<K,V,W>	forSideInput(java.lang.String pTransformId, java.lang.String sideInputId, Coder<K> keyCoder, Coder<V> valueCoder, Coder<W> windowCoder) Returns a StateRequestHandlers.MultimapSideInputHandler for the given pTransformId and sideInputId.
static StateRequestHandlers.MultimapSideInputHandlerFactory	unsupported() Throws a UnsupportedOperationException on the first access.

Method Detail

forSideInput

<K,V,W extends BoundedWindow> StateRequestHandlers.MultimapSideInputHandler<K,V,W> forSideInput(java.lang.String pTransformId,
                                                                                                java.lang.String sideInputId,
                                                                                                Coder<K> keyCoder,
                                                                                                Coder<V> valueCoder,
                                                                                                Coder<W> windowCoder)

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

unsupported

static StateRequestHandlers.MultimapSideInputHandlerFactory unsupported()

Throws a UnsupportedOperationException on the first access.