org.apache.beam.runners.fnexecution.state

Class StateRequestHandlers

java.lang.Object

org.apache.beam.runners.fnexecution.state.StateRequestHandlers

public class StateRequestHandlers
extends java.lang.Object

A set of utility methods which construct StateRequestHandlers.

TODO: Add a variant which works on ByteStrings to remove encoding/decoding overhead.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	StateRequestHandlers.BagUserStateHandler<K,V,W extends BoundedWindow> A handler for bag user state.
static interface	StateRequestHandlers.BagUserStateHandlerFactory A factory which constructs StateRequestHandlers.BagUserStateHandlers.
static interface	StateRequestHandlers.MultimapSideInputHandler<K,V,W extends BoundedWindow> A handler for multimap side inputs.
static interface	StateRequestHandlers.MultimapSideInputHandlerFactory A factory which constructs StateRequestHandlers.MultimapSideInputHandlers.

Constructor Summary

Constructors

Constructor and Description
StateRequestHandlers()

Method Summary

Modifier and Type	Method and Description
static StateRequestHandler	forMultimapSideInputHandlerFactory(ProcessBundleDescriptors.ExecutableProcessBundleDescriptor processBundleDescriptor, StateRequestHandlers.MultimapSideInputHandlerFactory multimapSideInputHandlerFactory) Returns an adapter which converts a StateRequestHandlers.MultimapSideInputHandlerFactory to a StateRequestHandler.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StateRequestHandlers

public StateRequestHandlers()

Method Detail

forMultimapSideInputHandlerFactory

public static StateRequestHandler forMultimapSideInputHandlerFactory(ProcessBundleDescriptors.ExecutableProcessBundleDescriptor processBundleDescriptor,
                                                                     StateRequestHandlers.MultimapSideInputHandlerFactory multimapSideInputHandlerFactory)

Returns an adapter which converts a StateRequestHandlers.MultimapSideInputHandlerFactory to a StateRequestHandler.

The StateRequestHandlers.MultimapSideInputHandlerFactory is required to handle all multimap side inputs contained within the ProcessBundleDescriptors.ExecutableProcessBundleDescriptor. See ProcessBundleDescriptors.ExecutableProcessBundleDescriptor.getMultimapSideInputSpecs() for the set of multimap side inputs that are contained.

Instances of StateRequestHandlers.MultimapSideInputHandlers returned by the StateRequestHandlers.MultimapSideInputHandlerFactory are cached.