org.apache.flink.table.runtime.dataview

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 namespace

EK - the external type of the MapView key

EV - the external type of the MapView 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 and Description
static class	StateMapView.KeyedStateMapViewWithKeysNotNull<N,EK,EV> A state MapView which does not support nullable keys and namespace.
static class	StateMapView.KeyedStateMapViewWithKeysNullable<N,EK,EV> A state MapView which supports nullable keys but does not support namespace.
static class	StateMapView.NamespacedStateMapViewWithKeysNotNull<N,EK,EV> A state MapView which supports namespace but does not support nullable keys.
static class	StateMapView.NamespacedStateMapViewWithKeysNullable<N,EK,EV> A state MapView which supports nullable keys and namespace.

Field Summary

Fields inherited from class org.apache.flink.table.api.dataview.MapView

keyType, valueType

Constructor Summary

Constructors

Constructor and Description
StateMapView()

Method Summary

Modifier and Type	Method and Description
Map<EK,EV>	getMap() Returns the entire view's content as an instance of Map.
void	setMap(Map<EK,EV> map) Replaces the entire view's content with the content of the given Map.

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

Methods inherited from interface org.apache.flink.table.api.dataview.DataView

clear

Constructor Detail

StateMapView

public StateMapView()

Method Detail

getMap

public Map<EK,EV> getMap()

Description copied from class: MapView

Returns the entire view's content as an instance of Map.

Overrides:

getMap in class MapView<EK,EV>

setMap

public void setMap(Map<EK,EV> map)

Description copied from class: MapView

Replaces the entire view's content with the content of the given Map.

Overrides:

setMap in class MapView<EK,EV>