Class StateListView.KeyedStateListView<N,T>
- java.lang.Object
-
- org.apache.flink.table.api.dataview.ListView<EE>
-
- org.apache.flink.table.runtime.dataview.StateListView<N,T>
-
- org.apache.flink.table.runtime.dataview.StateListView.KeyedStateListView<N,T>
-
- All Implemented Interfaces:
DataView
,StateDataView<N>
- Enclosing class:
- StateListView<N,EE>
public static final class StateListView.KeyedStateListView<N,T> extends StateListView<N,T>
StateListView.KeyedStateListView
is an default implementation ofStateListView
whose underlying representation is a keyed state.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.table.runtime.dataview.StateListView
StateListView.KeyedStateListView<N,T>, StateListView.NamespacedStateListView<N,T>
-
-
Field Summary
-
Fields inherited from class org.apache.flink.table.api.dataview.ListView
elementType
-
-
Constructor Summary
Constructors Constructor Description KeyedStateListView(ListState<T> listState)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ListState<T>
getListState()
void
setCurrentNamespace(N namespace)
Sets current namespace for state.-
Methods inherited from class org.apache.flink.table.runtime.dataview.StateListView
add, addAll, clear, get, getList, remove, setList
-
Methods inherited from class org.apache.flink.table.api.dataview.ListView
equals, hashCode, newListViewDataType
-
-
-
-
Method Detail
-
setCurrentNamespace
public void setCurrentNamespace(N namespace)
Description copied from interface:StateDataView
Sets current namespace for state.
-
getListState
protected ListState<T> getListState()
- Specified by:
getListState
in classStateListView<N,T>
-
-