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 and Description
<V,W extends BoundedWindow> StateRequestHandlers.IterableSideInputHandler<V,W>	forIterableSideInput(java.lang.String pTransformId, java.lang.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(java.lang.String pTransformId, java.lang.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 Detail

forIterableSideInput

<V,W extends BoundedWindow> StateRequestHandlers.IterableSideInputHandler<V,W> forIterableSideInput(java.lang.String pTransformId,
                                                                                                    java.lang.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(java.lang.String pTransformId,
                                                                                                        java.lang.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.