Uses of Interface
org.apache.flink.table.data.MapData

Packages that use MapData

Package	Description
org.apache.flink.connector.file.table
org.apache.flink.orc.vector
org.apache.flink.table.data
org.apache.flink.table.data.binary
org.apache.flink.table.data.columnar
org.apache.flink.table.data.columnar.vector
org.apache.flink.table.data.columnar.vector.heap
org.apache.flink.table.data.conversion
org.apache.flink.table.data.util
org.apache.flink.table.data.utils
org.apache.flink.table.data.writer
org.apache.flink.table.runtime.arrow.vectors
org.apache.flink.table.runtime.functions.aggregate
org.apache.flink.table.runtime.functions.scalar
org.apache.flink.table.runtime.functions.table
org.apache.flink.table.runtime.typeutils
org.apache.flink.table.runtime.typeutils.serializers.python

Uses of MapData in org.apache.flink.connector.file.table

Methods in org.apache.flink.connector.file.table that return MapData

Modifier and Type	Method and Description
MapData	EnrichedRowData.getMap(int pos)

Uses of MapData in org.apache.flink.orc.vector

Methods in org.apache.flink.orc.vector that return MapData

Modifier and Type	Method and Description
MapData	OrcMapColumnVector.getMap(int i)

Uses of MapData in org.apache.flink.table.data

Classes in org.apache.flink.table.data that implement MapData

Modifier and Type	Class and Description
class	GenericMapData An internal data structure representing data of MapType or MultisetType.

Methods in org.apache.flink.table.data that return MapData

Modifier and Type	Method and Description
MapData	UpdatableRowData.getMap(int pos)
MapData	BoxedWrapperRowData.getMap(int pos)
MapData	RowData.getMap(int pos) Returns the map value at the given position.
MapData	GenericRowData.getMap(int pos)
MapData	GenericArrayData.getMap(int pos)
MapData	ArrayData.getMap(int pos) Returns the map value at the given position.

Uses of MapData in org.apache.flink.table.data.binary

Classes in org.apache.flink.table.data.binary that implement MapData

Modifier and Type	Class and Description
class	BinaryMapData [4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray].

Methods in org.apache.flink.table.data.binary that return MapData

Modifier and Type	Method and Description
MapData	NestedRowData.getMap(int pos)
MapData	BinaryArrayData.getMap(int pos)
MapData	BinaryRowData.getMap(int pos)
static MapData	BinarySegmentUtils.readMapData(MemorySegment[] segments, int baseOffset, long offsetAndSize) Gets an instance of MapData from underlying MemorySegment.

Uses of MapData in org.apache.flink.table.data.columnar

Classes in org.apache.flink.table.data.columnar that implement MapData

Modifier and Type	Class and Description
class	ColumnarMapData Columnar map to support access to vector column data.

Methods in org.apache.flink.table.data.columnar that return MapData

Modifier and Type	Method and Description
MapData	ColumnarRowData.getMap(int pos)
MapData	ColumnarArrayData.getMap(int pos)

Uses of MapData in org.apache.flink.table.data.columnar.vector

Methods in org.apache.flink.table.data.columnar.vector that return MapData

Modifier and Type	Method and Description
MapData	MapColumnVector.getMap(int i)
MapData	VectorizedColumnBatch.getMap(int rowId, int colId)

Uses of MapData in org.apache.flink.table.data.columnar.vector.heap

Methods in org.apache.flink.table.data.columnar.vector.heap that return MapData

Modifier and Type	Method and Description
MapData	HeapMapVector.getMap(int i)

Uses of MapData in org.apache.flink.table.data.conversion

Methods in org.apache.flink.table.data.conversion that return MapData

Modifier and Type	Method and Description
MapData	MapMapConverter.toInternal(Map<K,V> external)

Methods in org.apache.flink.table.data.conversion with parameters of type MapData

Modifier and Type	Method and Description
Map<K,V>	MapMapConverter.toExternal(MapData internal)

Uses of MapData in org.apache.flink.table.data.util

Methods in org.apache.flink.table.data.util with parameters of type MapData

Modifier and Type	Method and Description
static Map<Object,Object>	MapDataUtil.convertToJavaMap(MapData map, LogicalType keyType, LogicalType valueType) Converts a MapData into Java Map, the keys and values of the Java map still holds objects of internal data structures.

Uses of MapData in org.apache.flink.table.data.utils

Methods in org.apache.flink.table.data.utils that return MapData

Modifier and Type	Method and Description
MapData	JoinedRowData.getMap(int pos)
MapData	ProjectedRowData.getMap(int pos)

Uses of MapData in org.apache.flink.table.data.writer

Methods in org.apache.flink.table.data.writer with parameters of type MapData

Modifier and Type	Method and Description
void	BinaryWriter.writeMap(int pos, MapData value, MapDataSerializer serializer)

Uses of MapData in org.apache.flink.table.runtime.arrow.vectors

Methods in org.apache.flink.table.runtime.arrow.vectors that return MapData

Modifier and Type	Method and Description
MapData	ArrowMapColumnVector.getMap(int i)

Uses of MapData in org.apache.flink.table.runtime.functions.aggregate

Methods in org.apache.flink.table.runtime.functions.aggregate that return MapData

Modifier and Type	Method and Description
MapData	CollectAggFunction.getValue(CollectAggFunction.CollectAccumulator<T> accumulator)

Uses of MapData in org.apache.flink.table.runtime.functions.scalar

Methods in org.apache.flink.table.runtime.functions.scalar that return MapData

Modifier and Type	Method and Description
MapData	MapFromArraysFunction.eval(ArrayData keysArray, ArrayData valuesArray)
MapData	MapUnionFunction.eval(MapData... maps)

Methods in org.apache.flink.table.runtime.functions.scalar with parameters of type MapData

Modifier and Type	Method and Description
MapData	MapUnionFunction.eval(MapData... maps)
ArrayData	MapEntriesFunction.eval(MapData input)
ArrayData	MapKeysFunction.eval(MapData input)
ArrayData	MapValuesFunction.eval(MapData input)

Uses of MapData in org.apache.flink.table.runtime.functions.table

Methods in org.apache.flink.table.runtime.functions.table with parameters of type MapData

Modifier and Type	Method and Description
void	UnnestRowsFunction.CollectionUnnestTableFunction.eval(MapData mapData)
void	UnnestRowsFunction.MapUnnestTableFunction.eval(MapData mapData)

Uses of MapData in org.apache.flink.table.runtime.typeutils

Methods in org.apache.flink.table.runtime.typeutils that return MapData

Modifier and Type	Method and Description
MapData	MapDataSerializer.copy(MapData from) NOTE: Map should be a HashMap, when we insert the key/value pairs of the TreeMap into a HashMap, problems maybe occur.
MapData	MapDataSerializer.copy(MapData from, MapData reuse)
MapData	MapDataSerializer.createInstance()
MapData	MapDataSerializer.deserialize(DataInputView source)
MapData	MapDataSerializer.deserialize(MapData reuse, DataInputView source)

Methods in org.apache.flink.table.runtime.typeutils that return types with arguments of type MapData

Modifier and Type	Method and Description
TypeSerializer<MapData>	MapDataSerializer.duplicate()
TypeSerializerSchemaCompatibility<MapData>	MapDataSerializer.MapDataSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<MapData> oldSerializerSnapshot)
TypeSerializer<MapData>	MapDataSerializer.MapDataSerializerSnapshot.restoreSerializer()
TypeSerializerSnapshot<MapData>	MapDataSerializer.snapshotConfiguration()

Methods in org.apache.flink.table.runtime.typeutils with parameters of type MapData

Modifier and Type	Method and Description
MapData	MapDataSerializer.copy(MapData from) NOTE: Map should be a HashMap, when we insert the key/value pairs of the TreeMap into a HashMap, problems maybe occur.
MapData	MapDataSerializer.copy(MapData from, MapData reuse)
MapData	MapDataSerializer.deserialize(MapData reuse, DataInputView source)
void	MapDataSerializer.serialize(MapData record, DataOutputView target)
BinaryMapData	MapDataSerializer.toBinaryMap(MapData from)

Method parameters in org.apache.flink.table.runtime.typeutils with type arguments of type MapData

Modifier and Type	Method and Description
TypeSerializerSchemaCompatibility<MapData>	MapDataSerializer.MapDataSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<MapData> oldSerializerSnapshot)

Uses of MapData in org.apache.flink.table.runtime.typeutils.serializers.python

Methods in org.apache.flink.table.runtime.typeutils.serializers.python that return MapData

Modifier and Type	Method and Description
MapData	MapDataSerializer.deserialize(DataInputView source)
MapData	MapDataSerializer.deserialize(MapData reuse, DataInputView source)

Methods in org.apache.flink.table.runtime.typeutils.serializers.python that return types with arguments of type MapData

Modifier and Type	Method and Description
TypeSerializer<MapData>	MapDataSerializer.duplicate()
TypeSerializerSchemaCompatibility<MapData>	MapDataSerializer.BaseMapSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<MapData> oldSerializerSnapshot)
TypeSerializer<MapData>	MapDataSerializer.BaseMapSerializerSnapshot.restoreSerializer()
TypeSerializerSnapshot<MapData>	MapDataSerializer.snapshotConfiguration()

Methods in org.apache.flink.table.runtime.typeutils.serializers.python with parameters of type MapData

Modifier and Type	Method and Description
MapData	MapDataSerializer.deserialize(MapData reuse, DataInputView source)
void	MapDataSerializer.serialize(MapData map, DataOutputView target)

Method parameters in org.apache.flink.table.runtime.typeutils.serializers.python with type arguments of type MapData

Modifier and Type	Method and Description
TypeSerializerSchemaCompatibility<MapData>	MapDataSerializer.BaseMapSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<MapData> oldSerializerSnapshot)