Class StateMapView<N,EK,EV>
- java.lang.Object
-
- org.apache.flink.table.api.dataview.MapView<EK,EV>
-
- org.apache.flink.table.runtime.dataview.StateMapView<N,EK,EV>
-
- Type Parameters:
N
- the type of namespaceEK
- the external type of theMapView
keyEV
- the external type of theMapView
value
- All Implemented Interfaces:
DataView
,StateDataView<N>
- Direct Known Subclasses:
StateMapView.KeyedStateMapViewWithKeysNotNull
,StateMapView.KeyedStateMapViewWithKeysNullable
,StateMapView.NamespacedStateMapViewWithKeysNotNull
,StateMapView.NamespacedStateMapViewWithKeysNullable
@Internal public abstract class StateMapView<N,EK,EV> extends MapView<EK,EV> implements StateDataView<N>
MapView
which is implemented using state backends.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
StateMapView.KeyedStateMapViewWithKeysNotNull<N,EK,EV>
A stateMapView
which does not support nullable keys and namespace.static class
StateMapView.KeyedStateMapViewWithKeysNullable<N,EK,EV>
A stateMapView
which supports nullable keys but does not support namespace.static class
StateMapView.NamespacedStateMapViewWithKeysNotNull<N,EK,EV>
A stateMapView
which supports namespace but does not support nullable keys.static class
StateMapView.NamespacedStateMapViewWithKeysNullable<N,EK,EV>
A stateMapView
which supports nullable keys and namespace.
-
Constructor Summary
Constructors Constructor Description StateMapView()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Map<EK,EV>
getMap()
Returns the entire view's content as an instance ofMap
.void
setMap(Map<EK,EV> map)
Replaces the entire view's content with the content of the givenMap
.-
Methods inherited from class org.apache.flink.table.api.dataview.MapView
clear, contains, entries, equals, get, hashCode, isEmpty, iterator, keys, newMapViewDataType, put, putAll, remove, values
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.table.runtime.dataview.StateDataView
setCurrentNamespace
-
-