Package | Description |
---|---|
org.apache.flink.table.dataview | |
org.apache.flink.table.planner.functions.aggfunctions | |
org.apache.flink.table.runtime.dataview |
Modifier and Type | Method and Description |
---|---|
MapView<K,V> |
MapViewSerializer.copy(MapView<K,V> from) |
MapView<K,V> |
MapViewSerializer.copy(MapView<K,V> from,
MapView<K,V> reuse) |
MapView<K,V> |
MapViewSerializer.createInstance() |
MapView<K,V> |
MapViewSerializer.deserialize(DataInputView source) |
MapView<K,V> |
MapViewSerializer.deserialize(MapView<K,V> reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<MapView<K,V>> |
MapViewTypeInfo.createSerializer(ExecutionConfig config) |
TypeInformation<MapView<K,V>> |
MapViewTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters) |
TypeSerializer<MapView<K,V>> |
MapViewSerializer.duplicate() |
Class<MapView<K,V>> |
MapViewTypeInfo.getTypeClass() |
TypeSerializerSnapshot<MapView<K,V>> |
MapViewSerializer.snapshotConfiguration() |
<U> TypeSerializerSnapshot<MapView<K,V>> |
MapViewSerializer.transformLegacySerializerSnapshot(TypeSerializerSnapshot<U> legacySnapshot)
We need to override this as a
LegacySerializerSnapshotTransformer because in Flink
1.6.x and below, this serializer was incorrectly returning directly the snapshot of the
nested map serializer as its own snapshot. |
Modifier and Type | Method and Description |
---|---|
MapView<K,V> |
MapViewSerializer.copy(MapView<K,V> from) |
MapView<K,V> |
MapViewSerializer.copy(MapView<K,V> from,
MapView<K,V> reuse) |
MapView<K,V> |
MapViewSerializer.copy(MapView<K,V> from,
MapView<K,V> reuse) |
MapView<K,V> |
MapViewSerializer.deserialize(MapView<K,V> reuse,
DataInputView source) |
void |
MapViewSerializer.serialize(MapView<K,V> record,
DataOutputView target) |
Modifier and Type | Field and Description |
---|---|
MapView<T,Long> |
MinWithRetractAggFunction.MinWithRetractAccumulator.map |
MapView<T,Integer> |
CollectAggFunction.CollectAccumulator.map |
MapView<T,Long> |
MaxWithRetractAggFunction.MaxWithRetractAccumulator.map |
Modifier and Type | Class and Description |
---|---|
class |
StateMapView<N,MK,MV>
MapView which is implemented using state backends.
|
static class |
StateMapView.KeyedStateMapViewWithKeysNotNull<N,MK,MV>
A state MapView which do not support nullable keys and namespace.
|
static class |
StateMapView.KeyedStateMapViewWithKeysNullable<N,MK,MV>
A state MapView which support nullable keys, but not support namespace.
|
static class |
StateMapView.NamespacedStateMapViewWithKeysNotNull<N,MK,MV>
A state MapView which support namespace but not support nullable keys.
|
static class |
StateMapView.NamespacedStateMapViewWithKeysNullable<N,MK,MV>
A state MapView which support nullable keys and namespace.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.