Package org.apache.flink.streaming.api.runners.python.beam.state

Interface Summary

Interface	Description
BeamStateHandler<S>	Interface for doing actual operations on Flink state based on BeamFnApi.StateRequest.
BeamStateStore	Interface for getting the underlying state based on Beam state request (keyed state or operator state).

Class Summary

Class	Description
AbstractBeamStateHandler<S>	Abstract class extends BeamStateHandler, which implements the common handle logic.
BeamBagStateHandler	BeamBagStateHandler handles operations on ListState, which backs Beam bag states.
BeamKeyedStateStore	A BeamStateStore that returns keyed states based on BeamFnApi.StateRequest.
BeamMapStateHandler	BeamMapStateHandler handles operations on a MapState.
BeamOperatorStateStore	A BeamStateStore that returns operator states based on BeamFnApi.StateRequest.
BeamStateRequestHandler	The handler for Beam state requests sent from Python side, which does actual operations on Flink state.

Enum Summary

Enum	Description
IterateType	The type of the Python map state iterate request.