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 | 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 | Description |
---|---|
IterateType |
The type of the Python map state iterate request.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.