Package org.apache.beam.runners.fnexecution.state

State API services.

See: Description

Interface Summary

Interface	Description
StateDelegator	The StateDelegator is able to delegate BeamFnApi.StateRequests to a set of registered handlers.
StateDelegator.Registration	Allows callers to deregister from receiving further state requests.
StateRequestHandler	Handler for StateRequests.
StateRequestHandlers.BagUserStateHandler<K,V,W extends BoundedWindow>	A handler for bag user state.
StateRequestHandlers.BagUserStateHandlerFactory<K,V,W extends BoundedWindow>	A factory which constructs StateRequestHandlers.BagUserStateHandlers.
StateRequestHandlers.SideInputHandler<V,W extends BoundedWindow>	A handler for side inputs.
StateRequestHandlers.SideInputHandlerFactory	A factory which constructs StateRequestHandlers.SideInputHandlers.

Class Summary

Class	Description
GrpcStateService	An implementation of the Beam Fn State service.
InMemoryBagUserStateFactory<K,V,W extends BoundedWindow>	Holds user state in memory.
StateRequestHandlers	A set of utility methods which construct StateRequestHandlers.

Package org.apache.beam.runners.fnexecution.state Description

State API services.