Package 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	Description
BeamOperatorStateStore(OperatorStateBackend operatorStateBackend)

Method Summary

Modifier and Type	Method	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

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