org.apache.flink.table.runtime.dataview

Class UnsupportedStateDataViewStore

java.lang.Object

org.apache.flink.table.runtime.dataview.UnsupportedStateDataViewStore

All Implemented Interfaces:

StateDataViewStore

public final class UnsupportedStateDataViewStore
extends Object
implements StateDataViewStore

A StateDataViewStore to throw UnsupportedOperationException when creating StateDataView.

Constructor Summary

Constructors

Constructor and Description
UnsupportedStateDataViewStore(RuntimeContext runtimeContext)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

UnsupportedStateDataViewStore

public UnsupportedStateDataViewStore(RuntimeContext runtimeContext)

Method Detail

getStateMapView

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

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

Throws:

Exception

getStateListView

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

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

Throws:

Exception

getRuntimeContext

public RuntimeContext getRuntimeContext()

Specified by:

getRuntimeContext in interface StateDataViewStore