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(org.apache.flink.runtime.state.OperatorStateBackend operatorStateBackend)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.common.state.ListState<byte[]>	getListState(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request)	Currently list state and union-list state is not supported.
org.apache.flink.api.common.state.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(org.apache.flink.runtime.state.OperatorStateBackend operatorStateBackend)

Method Detail

getListState

public org.apache.flink.api.common.state.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 org.apache.flink.api.common.state.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