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

Packages that use ArrayData

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.model
org.apache.flink.cdc.runtime.serializer.data
org.apache.flink.cdc.runtime.serializer.data.writer

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

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

Modifier and Type	Class	Description
class	GenericArrayData	An internal data structure representing data of ArrayType.

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

Modifier and Type	Method	Description
ArrayData	ArrayData.getArray(int pos)	Returns the array value at the given position.
ArrayData	GenericArrayData.getArray(int pos)
ArrayData	GenericRecordData.getArray(int pos)
ArrayData	RecordData.getArray(int pos)	Returns the array value at the given position.
ArrayData	GenericMapData.keyArray()
ArrayData	MapData.keyArray()	Returns an array view of the keys contained in this map.
ArrayData	GenericMapData.valueArray()
ArrayData	MapData.valueArray()	Returns an array view of the values contained in this map.

Methods in org.apache.flink.cdc.common.data with parameters of type ArrayData

Modifier and Type	Method	Description
Object	ArrayData.ElementGetter.getElementOrNull(ArrayData array, int pos)

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

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

Modifier and Type	Class	Description
class	BinaryArrayData	A binary implementation of ArrayData which is backed by MemorySegments.

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

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

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

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

Constructor	Description
CdcAsFlussArray(ArrayData flussArray)

Uses of ArrayData in org.apache.flink.cdc.runtime.model

Methods in org.apache.flink.cdc.runtime.model that return ArrayData

Modifier and Type	Method	Description
ArrayData	OpenAIEmbeddingModel.eval(String input)

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

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

Modifier and Type	Method	Description
ArrayData	ArrayDataSerializer.copy(ArrayData from)
ArrayData	ArrayDataSerializer.copy(ArrayData from, ArrayData reuse)
ArrayData	ArrayDataSerializer.createInstance()
ArrayData	ArrayDataSerializer.deserialize(ArrayData reuse, org.apache.flink.core.memory.DataInputView source)
ArrayData	ArrayDataSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)

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

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

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

Modifier and Type	Method	Description
ArrayData	ArrayDataSerializer.copy(ArrayData from)
ArrayData	ArrayDataSerializer.copy(ArrayData from, ArrayData reuse)
ArrayData	ArrayDataSerializer.deserialize(ArrayData reuse, org.apache.flink.core.memory.DataInputView source)
void	ArrayDataSerializer.serialize(ArrayData record, org.apache.flink.core.memory.DataOutputView target)
BinaryArrayData	ArrayDataSerializer.toBinaryArray(ArrayData from)

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

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<ArrayData>	ArrayDataSerializer.ArrayDataSerializerSnapshot.resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<ArrayData> newSerializer)

Uses of ArrayData in org.apache.flink.cdc.runtime.serializer.data.writer

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

Modifier and Type	Method	Description
void	BinaryWriter.writeArray(int pos, ArrayData value, ArrayDataSerializer serializer)