org.apache.flink.table.runtime.dataview

Interface StateDataViewStore

All Known Implementing Classes:

PerKeyStateDataViewStore, PerWindowStateDataViewStore, UnsupportedStateDataViewStore

@Internal
public interface StateDataViewStore

This interface contains methods for registering StateDataView with a managed store.

Method Summary

Modifier and Type	Method and 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.

Method Detail

getStateMapView

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

Creates a state map view.

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

Throws:

Exception

getStateListView

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

Creates a state list view.

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

Throws:

Exception

getRuntimeContext

RuntimeContext getRuntimeContext()