Package 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	Description
BeamKeyedStateStore(org.apache.flink.runtime.state.KeyedStateBackend<?> keyedStateBackend, org.apache.flink.api.common.typeutils.TypeSerializer<?> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializer<?> namespaceSerializer)

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)	Parse BeamFnApi.StateRequest and return the corresponding ListState.
org.apache.flink.api.common.state.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

Constructor Detail

BeamKeyedStateStore

public BeamKeyedStateStore(org.apache.flink.runtime.state.KeyedStateBackend<?> keyedStateBackend,
                           org.apache.flink.api.common.typeutils.TypeSerializer<?> keySerializer,
                           @Nullable
                           org.apache.flink.api.common.typeutils.TypeSerializer<?> namespaceSerializer)

Method Detail

getListState

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