public class BatchSideInputHandlerFactory extends java.lang.Object implements StateRequestHandlers.SideInputHandlerFactory
StateRequestHandler
that uses a BatchSideInputHandlerFactory.SideInputGetter
to access side inputs.Modifier and Type | Class and Description |
---|---|
static interface |
BatchSideInputHandlerFactory.SideInputGetter
Returns the value for the side input with the given PCollection id from the runner.
|
Modifier and Type | Method and Description |
---|---|
<V,W extends BoundedWindow> |
forIterableSideInput(java.lang.String transformId,
java.lang.String sideInputId,
Coder<V> elementCoder,
Coder<W> windowCoder)
|
<K,V,W extends BoundedWindow> |
forMultimapSideInput(java.lang.String transformId,
java.lang.String sideInputId,
KvCoder<K,V> elementCoder,
Coder<W> windowCoder)
|
static BatchSideInputHandlerFactory |
forStage(org.apache.beam.sdk.util.construction.graph.ExecutableStage stage,
BatchSideInputHandlerFactory.SideInputGetter sideInputGetter)
Creates a new state handler for the given stage.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
unsupported
public static BatchSideInputHandlerFactory forStage(org.apache.beam.sdk.util.construction.graph.ExecutableStage stage, BatchSideInputHandlerFactory.SideInputGetter sideInputGetter)
public <V,W extends BoundedWindow> StateRequestHandlers.IterableSideInputHandler<V,W> forIterableSideInput(java.lang.String transformId, java.lang.String sideInputId, Coder<V> elementCoder, Coder<W> windowCoder)
StateRequestHandlers.SideInputHandlerFactory
StateRequestHandlers.IterableSideInputHandler
for the given pTransformId
, sideInputId
. The supplied elementCoder
and windowCoder
should be used to
encode/decode their respective values.forIterableSideInput
in interface StateRequestHandlers.SideInputHandlerFactory
public <K,V,W extends BoundedWindow> StateRequestHandlers.MultimapSideInputHandler<K,V,W> forMultimapSideInput(java.lang.String transformId, java.lang.String sideInputId, KvCoder<K,V> elementCoder, Coder<W> windowCoder)
StateRequestHandlers.SideInputHandlerFactory
StateRequestHandlers.MultimapSideInputHandler
for the given pTransformId
, sideInputId
. The supplied elementCoder
and windowCoder
should be used to
encode/decode their respective values.forMultimapSideInput
in interface StateRequestHandlers.SideInputHandlerFactory