Package | Description |
---|---|
org.apache.flink.streaming.api.runners.python.beam.state |
Class and Description |
---|
AbstractBeamStateHandler
Abstract class extends
BeamStateHandler , which implements the common handle logic. |
BeamStateHandler
Interface for doing actual operations on Flink state based on
BeamFnApi.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.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.