Uses of Interface
org.apache.flink.cdc.common.data.MapData

Packages that use MapData

Package	Description
org.apache.flink.cdc.common.data
org.apache.flink.cdc.common.data.binary
org.apache.flink.cdc.connectors.fluss.sink.row
org.apache.flink.cdc.runtime.serializer.data
org.apache.flink.cdc.runtime.serializer.data.util
org.apache.flink.cdc.runtime.serializer.data.writer

Uses of MapData in org.apache.flink.cdc.common.data

Classes in org.apache.flink.cdc.common.data that implement MapData

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

Methods in org.apache.flink.cdc.common.data that return MapData

Modifier and Type	Method	Description
MapData	ArrayData.getMap(int pos)	Returns the map value at the given position.
MapData	GenericArrayData.getMap(int pos)
MapData	GenericRecordData.getMap(int pos)
MapData	RecordData.getMap(int pos)	Returns the map value at the given position.

Uses of MapData in org.apache.flink.cdc.common.data.binary

Classes in org.apache.flink.cdc.common.data.binary that implement MapData

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

Methods in org.apache.flink.cdc.common.data.binary that return MapData

Modifier and Type	Method	Description
MapData	BinaryArrayData.getMap(int pos)
MapData	BinaryRecordData.getMap(int pos)
static MapData	BinarySegmentUtils.readMapData(org.apache.flink.core.memory.MemorySegment[] segments, int baseOffset, long offsetAndSize)	Gets an instance of MapData from underlying MemorySegment.

Uses of MapData in org.apache.flink.cdc.connectors.fluss.sink.row

Constructors in org.apache.flink.cdc.connectors.fluss.sink.row with parameters of type MapData

Constructor	Description
CdcAsFlussMap(MapData cdcMap)

Uses of MapData in org.apache.flink.cdc.runtime.serializer.data

Methods in org.apache.flink.cdc.runtime.serializer.data that return MapData

Modifier and Type	Method	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(MapData reuse, org.apache.flink.core.memory.DataInputView source)
MapData	MapDataSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)

Methods in org.apache.flink.cdc.runtime.serializer.data that return types with arguments of type MapData

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializer<MapData>	MapDataSerializer.duplicate()
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<MapData>	MapDataSerializer.MapDataSerializerSnapshot.resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<MapData> newSerializer)
org.apache.flink.api.common.typeutils.TypeSerializer<MapData>	MapDataSerializer.MapDataSerializerSnapshot.restoreSerializer()
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<MapData>	MapDataSerializer.snapshotConfiguration()

Methods in org.apache.flink.cdc.runtime.serializer.data with parameters of type MapData

Modifier and Type	Method	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, org.apache.flink.core.memory.DataInputView source)
void	MapDataSerializer.serialize(MapData record, org.apache.flink.core.memory.DataOutputView target)
BinaryMapData	MapDataSerializer.toBinaryMap(MapData from)

Method parameters in org.apache.flink.cdc.runtime.serializer.data with type arguments of type MapData

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<MapData>	MapDataSerializer.MapDataSerializerSnapshot.resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<MapData> newSerializer)

Uses of MapData in org.apache.flink.cdc.runtime.serializer.data.util

Methods in org.apache.flink.cdc.runtime.serializer.data.util with parameters of type MapData

Modifier and Type	Method	Description
static Map<Object,Object>	MapDataUtil.convertToJavaMap(MapData map, DataType keyType, DataType 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.cdc.runtime.serializer.data.writer

Methods in org.apache.flink.cdc.runtime.serializer.data.writer with parameters of type MapData

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