org.apache.flink.cdc.common.data.binary

类 BinaryMapData

java.lang.Object

org.apache.flink.cdc.common.data.binary.BinarySection

org.apache.flink.cdc.common.data.binary.BinaryMapData

所有已实现的接口:

BinaryFormat, MapData

@Internal
public class BinaryMapData
extends BinarySection
implements MapData

[4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray].

BinaryMap are influenced by Apache Spark UnsafeMapData.

字段概要

从类继承的字段 org.apache.flink.cdc.common.data.binary.BinarySection

offset, segments, sizeInBytes

从接口继承的字段 org.apache.flink.cdc.common.data.binary.BinaryFormat

HIGHEST_FIRST_BIT, HIGHEST_SECOND_TO_EIGHTH_BIT, MAX_FIX_PART_DATA_SIZE

构造器概要

构造器

构造器和说明
BinaryMapData()

方法概要

限定符和类型	方法和说明
BinaryMapData	copy()
BinaryMapData	copy(BinaryMapData reuse)
int	hashCode()
BinaryArrayData	keyArray() Returns an array view of the keys contained in this map.
void	pointTo(org.apache.flink.core.memory.MemorySegment[] segments, int offset, int sizeInBytes)
int	size() Returns the number of key-value mappings in this map.
Map<?,?>	toJavaMap(DataType keyType, DataType valueType)
BinaryArrayData	valueArray() Returns an array view of the values contained in this map.
static BinaryMapData	valueOf(BinaryArrayData key, BinaryArrayData value)

从类继承的方法 org.apache.flink.cdc.common.data.binary.BinarySection

equals, getOffset, getSegments, getSizeInBytes, pointTo

从类继承的方法 java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

BinaryMapData

public BinaryMapData()

方法详细资料

size

public int size()

从接口复制的说明: MapData

Returns the number of key-value mappings in this map.

指定者:

size 在接口中 MapData

pointTo

public void pointTo(org.apache.flink.core.memory.MemorySegment[] segments,
                    int offset,
                    int sizeInBytes)

覆盖:

pointTo 在类中 BinarySection

keyArray

public BinaryArrayData keyArray()

从接口复制的说明: MapData

Returns an array view of the keys contained in this map.

A key-value pair has the same index in the key array and value array.

指定者:

keyArray 在接口中 MapData

valueArray

public BinaryArrayData valueArray()

从接口复制的说明: MapData

Returns an array view of the values contained in this map.

A key-value pair has the same index in the key array and value array.

指定者:

valueArray 在接口中 MapData

toJavaMap

public Map<?,?> toJavaMap(DataType keyType,
                          DataType valueType)

copy

public BinaryMapData copy()

copy

public BinaryMapData copy(BinaryMapData reuse)

hashCode

public int hashCode()

覆盖:

hashCode 在类中 BinarySection

valueOf

public static BinaryMapData valueOf(BinaryArrayData key,
                                    BinaryArrayData value)