Uses of Interface
org.apache.flink.streaming.api.runners.python.beam.state.BeamStateHandler

Packages that use BeamStateHandler

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

Uses of BeamStateHandler in org.apache.flink.streaming.api.runners.python.beam.state

Classes in org.apache.flink.streaming.api.runners.python.beam.state that implement BeamStateHandler

Modifier and Type	Class	Description
class	AbstractBeamStateHandler<S>	Abstract class extends BeamStateHandler, which implements the common handle logic.
class	BeamBagStateHandler	BeamBagStateHandler handles operations on ListState, which backs Beam bag states.
class	BeamMapStateHandler	BeamMapStateHandler handles operations on a MapState.

Constructors in org.apache.flink.streaming.api.runners.python.beam.state with parameters of type BeamStateHandler

Constructor	Description
BeamStateRequestHandler(BeamStateStore keyedStateStore, BeamStateStore operatorStateStore, BeamStateHandler<org.apache.flink.api.common.state.ListState<byte[]>> bagStateHandler, BeamStateHandler<org.apache.flink.api.common.state.MapState<ByteArrayWrapper,byte[]>> mapStateHandler)