Uses of Package
org.apache.flink.streaming.api.runners.python.beam.state
-
Packages that use org.apache.flink.streaming.api.runners.python.beam.state Package Description org.apache.flink.streaming.api.runners.python.beam.state -
Classes in org.apache.flink.streaming.api.runners.python.beam.state used by org.apache.flink.streaming.api.runners.python.beam.state Class Description AbstractBeamStateHandler Abstract class extendsBeamStateHandler, which implements the common handle logic.BeamStateHandler Interface for doing actual operations on Flink state based onBeamFnApi.StateRequest.BeamStateRequestHandler The handler for Beam state requests sent from Python side, which does actual operations on Flink state.BeamStateStore Interface for getting the underlying state based on Beam state request (keyed state or operator state).IterateType The type of the Python map state iterate request.