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

Packages that use BeamStateStore

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

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

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

Modifier and Type	Class	Description
class	BeamKeyedStateStore	A BeamStateStore that returns keyed states based on BeamFnApi.StateRequest.
class	BeamOperatorStateStore	A BeamStateStore that returns operator states based on BeamFnApi.StateRequest.

Methods in org.apache.flink.streaming.api.runners.python.beam.state that return BeamStateStore

Modifier and Type	Method	Description
static BeamStateStore	BeamStateStore.unsupported()

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

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)