org.apache.beam.runners.fnexecution.state

Interface StateRequestHandlers.SideInputHandlerFactory

Enclosing class:

StateRequestHandlers

@ThreadSafe
public static interface StateRequestHandlers.SideInputHandlerFactory

A factory which constructs StateRequestHandlers.SideInputHandlers.

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

Method Summary

Modifier and Type	Method and Description
<T,V,W extends BoundedWindow> StateRequestHandlers.SideInputHandler<V,W>	forSideInput(java.lang.String pTransformId, java.lang.String sideInputId, org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec accessPattern, Coder<T> elementCoder, Coder<W> windowCoder) Returns a StateRequestHandlers.SideInputHandler for the given pTransformId, sideInputId, and accessPattern.
static StateRequestHandlers.SideInputHandlerFactory	unsupported() Throws a UnsupportedOperationException on the first access.

Method Detail

forSideInput

<T,V,W extends BoundedWindow> StateRequestHandlers.SideInputHandler<V,W> forSideInput(java.lang.String pTransformId,
                                                                                      java.lang.String sideInputId,
                                                                                      org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec accessPattern,
                                                                                      Coder<T> elementCoder,
                                                                                      Coder<W> windowCoder)

Returns a StateRequestHandlers.SideInputHandler for the given pTransformId, sideInputId, and accessPattern. 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.