Uses of Class
org.apache.flink.cdc.common.data.DecimalData

Packages that use DecimalData

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.writer

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

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

Modifier and Type	Method	Description
DecimalData	DecimalData.copy()	Returns a copy of this DecimalData object.
static DecimalData	DecimalData.fromBigDecimal(BigDecimal bd, int precision, int scale)	Creates an instance of DecimalData from a BigDecimal and the given precision and scale.
static DecimalData	DecimalData.fromUnscaledBytes(byte[] unscaledBytes, int precision, int scale)	Creates an instance of DecimalData from an unscaled byte array value and the given precision and scale.
static DecimalData	DecimalData.fromUnscaledLong(long unscaledLong, int precision, int scale)	Creates an instance of DecimalData from an unscaled long value and the given precision and scale.
DecimalData	ArrayData.getDecimal(int pos, int precision, int scale)	Returns the decimal value at the given position.
DecimalData	GenericArrayData.getDecimal(int pos, int precision, int scale)
DecimalData	GenericRecordData.getDecimal(int pos, int precision, int scale)
DecimalData	RecordData.getDecimal(int pos, int precision, int scale)	Returns the decimal value at the given position.
static DecimalData	DecimalData.zero(int precision, int scale)	Creates an instance of DecimalData for a zero value with the given precision and scale.

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

Modifier and Type	Method	Description
int	DecimalData.compareTo(DecimalData that)

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

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

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

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

Modifier and Type	Method	Description
void	BinaryArrayData.setDecimal(int pos, DecimalData value, int precision)

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

Methods in org.apache.flink.cdc.connectors.fluss.sink.row with parameters of type DecimalData

Modifier and Type	Method	Description
static org.apache.fluss.row.Decimal	CdcAsFlussRow.fromFlinkDecimal(DecimalData decimal)

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

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

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

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

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<DecimalData>	DecimalDataSerializer.DecimalSerializerSnapshot.resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<DecimalData> newSerializer)
org.apache.flink.api.common.typeutils.TypeSerializer<DecimalData>	DecimalDataSerializer.DecimalSerializerSnapshot.restoreSerializer()
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<DecimalData>	DecimalDataSerializer.snapshotConfiguration()

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

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

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

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<DecimalData>	DecimalDataSerializer.DecimalSerializerSnapshot.resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<DecimalData> newSerializer)

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

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

Modifier and Type	Method	Description
void	BinaryWriter.writeDecimal(int pos, DecimalData value, int precision)