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.SideInputHandler<V,W extends BoundedWindow> A handler for side inputs.
static interface	StateRequestHandlers.SideInputHandlerFactory A factory which constructs StateRequestHandlers.SideInputHandlers.

Constructor Summary

Constructors

Constructor and Description
StateRequestHandlers()

Method Summary

Modifier and Type	Method and Description
static StateRequestHandler	delegateBasedUponType(java.util.EnumMap<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateKey.TypeCase,StateRequestHandler> handlers) Returns a StateRequestHandler which delegates to the supplied handler depending on the BeamFnApi.StateRequests type.
static StateRequestHandler	forBagUserStateHandlerFactory(ProcessBundleDescriptors.ExecutableProcessBundleDescriptor processBundleDescriptor, StateRequestHandlers.BagUserStateHandlerFactory bagUserStateHandlerFactory) Returns an adapter which converts a StateRequestHandlers.BagUserStateHandlerFactory to a StateRequestHandler.
static StateRequestHandler	forSideInputHandlerFactory(java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.SideInputSpec>> sideInputSpecs, StateRequestHandlers.SideInputHandlerFactory sideInputHandlerFactory) Returns an adapter which converts a StateRequestHandlers.SideInputHandlerFactory 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

delegateBasedUponType

public static StateRequestHandler delegateBasedUponType(java.util.EnumMap<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateKey.TypeCase,StateRequestHandler> handlers)

Returns a StateRequestHandler which delegates to the supplied handler depending on the BeamFnApi.StateRequests type.

An exception is thrown if a corresponding handler is not found.

forSideInputHandlerFactory

public static StateRequestHandler forSideInputHandlerFactory(java.util.Map<java.lang.String,java.util.Map<java.lang.String,ProcessBundleDescriptors.SideInputSpec>> sideInputSpecs,
                                                             StateRequestHandlers.SideInputHandlerFactory sideInputHandlerFactory)

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

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

Instances of StateRequestHandlers.SideInputHandlers returned by the StateRequestHandlers.SideInputHandlerFactory are cached.

forBagUserStateHandlerFactory

public static StateRequestHandler forBagUserStateHandlerFactory(ProcessBundleDescriptors.ExecutableProcessBundleDescriptor processBundleDescriptor,
                                                                StateRequestHandlers.BagUserStateHandlerFactory bagUserStateHandlerFactory)

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

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

Instances of StateRequestHandlers.SideInputHandlers returned by the StateRequestHandlers.SideInputHandlerFactory are cached.