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

Class BeamKeyedStateStore

java.lang.Object

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

All Implemented Interfaces:

BeamStateStore

public class BeamKeyedStateStore
extends Object
implements BeamStateStore

A BeamStateStore that returns keyed 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
BeamKeyedStateStore(KeyedStateBackend<?> keyedStateBackend, TypeSerializer<?> keySerializer, TypeSerializer<?> namespaceSerializer)

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.

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

BeamKeyedStateStore

public BeamKeyedStateStore(KeyedStateBackend<?> keyedStateBackend,
                           TypeSerializer<?> keySerializer,
                           @Nullable
                           TypeSerializer<?> namespaceSerializer)

Method Detail

getListState

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

Description copied from interface: BeamStateStore

Parse BeamFnApi.StateRequest and return the corresponding ListState.

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

Description copied from interface: BeamStateStore

Parse BeamFnApi.StateRequest and return the corresponding MapState.

Specified by:

getMapState in interface BeamStateStore

Throws:

Exception