Package org.apache.flink.table.runtime.dataview

Class PerKeyStateDataViewStore

java.lang.Object

org.apache.flink.table.runtime.dataview.PerKeyStateDataViewStore

All Implemented Interfaces:

StateDataViewStore

@Internal
public final class PerKeyStateDataViewStore
extends Object
implements StateDataViewStore

Default implementation of StateDataViewStore that currently forwards state registration to a RuntimeContext.

Constructor Summary

Constructors

Constructor	Description
PerKeyStateDataViewStore(RuntimeContext ctx)
PerKeyStateDataViewStore(RuntimeContext ctx, StateTtlConfig stateTtlConfig)

Method Summary

Modifier and Type	Method	Description
RuntimeContext	getRuntimeContext()
<N,EE> StateListView<N,EE>	getStateListView(String stateName, TypeSerializer<EE> elementSerializer)	Creates a state list view.
<N,EK,EV> StateMapView<N,EK,EV>	getStateMapView(String stateName, boolean supportNullKey, TypeSerializer<EK> keySerializer, TypeSerializer<EV> valueSerializer)	Creates a state map view.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PerKeyStateDataViewStore

public PerKeyStateDataViewStore(RuntimeContext ctx)

PerKeyStateDataViewStore

public PerKeyStateDataViewStore(RuntimeContext ctx,
                                StateTtlConfig stateTtlConfig)

Method Detail

getStateMapView

public <N,EK,EV> StateMapView<N,EK,EV> getStateMapView(String stateName,
                                                                               boolean supportNullKey,
                                                                               TypeSerializer<EK> keySerializer,
                                                                               TypeSerializer<EV> valueSerializer)

Description copied from interface: StateDataViewStore

Creates a state map view.

Specified by:

getStateMapView in interface StateDataViewStore

Type Parameters:

N - Type of the namespace

EK - External type of the keys in the map state

EV - External type of the values in the map state

Parameters:

stateName - The name of underlying state of the map view

supportNullKey - Whether the null key should be supported

keySerializer - The key serializer

valueSerializer - The value serializer

Returns:

a keyed map state

getStateListView

public <N,EE> StateListView<N,EE> getStateListView(String stateName,
                                                               TypeSerializer<EE> elementSerializer)

Description copied from interface: StateDataViewStore

Creates a state list view.

Specified by:

getStateListView in interface StateDataViewStore

Type Parameters:

N - Type of the namespace

EE - External type of the elements in the list state

Parameters:

stateName - The name of underlying state of the list view

elementSerializer - The element serializer

Returns:

a keyed list state

getRuntimeContext

public RuntimeContext getRuntimeContext()

Specified by:

getRuntimeContext in interface StateDataViewStore