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

Class BeamOperatorStateStore

java.lang.Object

org.apache.flink.streaming.api.runners.python.beam.state.BeamOperatorStateStore

All Implemented Interfaces:

BeamStateStore

public class BeamOperatorStateStore
extends Object
implements BeamStateStore

A BeamStateStore that returns operator states based on BeamFnApi.StateRequest.

Field Summary

Fields inherited from interface org.apache.flink.streaming.api.runners.python.beam.state.BeamStateStore

PYTHON_STATE_PREFIX

Constructor Summary

Constructors

Constructor and Description
BeamOperatorStateStore(OperatorStateBackend operatorStateBackend)

Method Summary

Modifier and Type	Method and Description
ListState<byte[]>	getListState(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request) Currently list state and union-list state is not supported.
MapState<ByteArrayWrapper,byte[]>	getMapState(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request) Returns a BroadcastState wrapped in MapState interface.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.api.runners.python.beam.state.BeamStateStore

unsupported

Constructor Detail

BeamOperatorStateStore

public BeamOperatorStateStore(OperatorStateBackend operatorStateBackend)

Method Detail

getListState

public ListState<byte[]> getListState(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request)
                               throws Exception

Currently list state and union-list state is not supported.

Specified by:

getListState in interface BeamStateStore

Throws:

Exception

getMapState

public MapState<ByteArrayWrapper,byte[]> getMapState(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request)
                                              throws Exception

Returns a BroadcastState wrapped in MapState interface.

Specified by:

getMapState in interface BeamStateStore

Throws:

Exception