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

Interface BeamStateStore

All Known Implementing Classes:

BeamKeyedStateStore, BeamOperatorStateStore

public interface BeamStateStore

Interface for getting the underlying state based on Beam state request (keyed state or operator state).

Field Summary

Fields

Modifier and Type	Field and Description
static String	PYTHON_STATE_PREFIX

Method Summary

Modifier and Type	Method and Description
ListState<byte[]>	getListState(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request) Parse BeamFnApi.StateRequest and return the corresponding ListState.
MapState<ByteArrayWrapper,byte[]>	getMapState(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request) Parse BeamFnApi.StateRequest and return the corresponding MapState.
static BeamStateStore	unsupported()

Field Detail

PYTHON_STATE_PREFIX

static final String PYTHON_STATE_PREFIX

See Also:

Constant Field Values

Method Detail

getListState

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

Parse BeamFnApi.StateRequest and return the corresponding ListState.

Throws:

Exception

getMapState

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

Parse BeamFnApi.StateRequest and return the corresponding MapState.

Throws:

Exception

unsupported

static BeamStateStore unsupported()