Uses of Class
org.apache.flink.table.data.DecimalData

Packages that use DecimalData

Package	Description
org.apache.flink.formats.parquet.vector
org.apache.flink.orc.nohive.vector
org.apache.flink.orc.vector
org.apache.flink.table.data
org.apache.flink.table.data.binary
org.apache.flink.table.data.conversion
org.apache.flink.table.data.vector
org.apache.flink.table.data.writer
org.apache.flink.table.planner.functions.aggfunctions
org.apache.flink.table.runtime.arrow.vectors
org.apache.flink.table.runtime.functions
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.typeutils
org.apache.flink.table.runtime.typeutils.serializers.python

Uses of DecimalData in org.apache.flink.formats.parquet.vector

Methods in org.apache.flink.formats.parquet.vector that return DecimalData

Modifier and Type	Method and Description
DecimalData	ParquetDecimalVector.getDecimal(int i, int precision, int scale)

Uses of DecimalData in org.apache.flink.orc.nohive.vector

Methods in org.apache.flink.orc.nohive.vector that return DecimalData

Modifier and Type	Method and Description
DecimalData	OrcNoHiveDecimalVector.getDecimal(int i, int precision, int scale)

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

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

Modifier and Type	Method and Description
DecimalData	OrcDecimalColumnVector.getDecimal(int i, int precision, int scale)

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

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

Modifier and Type	Method and Description
static DecimalData	DecimalDataUtils.abs(DecimalData decimal)
static DecimalData	DecimalDataUtils.add(DecimalData v1, DecimalData v2, int precision, int scale)
static DecimalData	DecimalDataUtils.castFrom(boolean val, int p, int s)
static DecimalData	DecimalDataUtils.castFrom(DecimalData dec, int precision, int scale)
static DecimalData	DecimalDataUtils.castFrom(double val, int p, int s)
static DecimalData	DecimalDataUtils.castFrom(long val, int p, int s)
static DecimalData	DecimalDataUtils.castFrom(String string, int precision, int scale)
static DecimalData	DecimalDataUtils.castToDecimal(DecimalData dec, int precision, int scale)
static DecimalData	DecimalDataUtils.ceil(DecimalData decimal)
DecimalData	DecimalData.copy() Returns a copy of this DecimalData object.
static DecimalData	DecimalDataUtils.divide(DecimalData v1, DecimalData v2, int precision, int scale)
static DecimalData	DecimalDataUtils.divideToIntegralValue(DecimalData value, DecimalData divisor, int precision, int scale) Returns a DecimalData whose value is the integer part of the quotient (this / divisor) rounded down.
static DecimalData	DecimalDataUtils.floor(DecimalData decimal)
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	ColumnarRowData.getDecimal(int pos, int precision, int scale)
DecimalData	ColumnarArrayData.getDecimal(int pos, int precision, int scale)
DecimalData	BoxedWrapperRowData.getDecimal(int pos, int precision, int scale)
DecimalData	UpdatableRowData.getDecimal(int pos, int precision, int scale)
DecimalData	JoinedRowData.getDecimal(int pos, int precision, int scale)
DecimalData	GenericRowData.getDecimal(int pos, int precision, int scale)
DecimalData	GenericArrayData.getDecimal(int pos, int precision, int scale)
DecimalData	RowData.getDecimal(int pos, int precision, int scale) Returns the decimal value at the given position.
DecimalData	ArrayData.getDecimal(int pos, int precision, int scale) Returns the decimal value at the given position.
static DecimalData	DecimalDataUtils.mod(DecimalData v1, DecimalData v2, int precision, int scale)
static DecimalData	DecimalDataUtils.multiply(DecimalData v1, DecimalData v2, int precision, int scale)
static DecimalData	DecimalDataUtils.negate(DecimalData decimal)
static DecimalData	DecimalDataUtils.sign(DecimalData b0) SQL SIGN operator applied to BigDecimal values.
static DecimalData	DecimalDataUtils.sround(DecimalData b0, int r) SQL ROUND operator applied to BigDecimal values.
static DecimalData	DecimalDataUtils.subtract(DecimalData v1, DecimalData v2, int precision, int scale)
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.table.data with parameters of type DecimalData

Modifier and Type	Method and Description
static DecimalData	DecimalDataUtils.abs(DecimalData decimal)
static DecimalData	DecimalDataUtils.add(DecimalData v1, DecimalData v2, int precision, int scale)
static DecimalData	DecimalDataUtils.castFrom(DecimalData dec, int precision, int scale)
static boolean	DecimalDataUtils.castToBoolean(DecimalData dec)
static byte	DecimalDataUtils.castToByte(DecimalData dec)
static DecimalData	DecimalDataUtils.castToDecimal(DecimalData dec, int precision, int scale)
static double	DecimalDataUtils.castToDouble(DecimalData dec)
static float	DecimalDataUtils.castToFloat(DecimalData dec)
static int	DecimalDataUtils.castToInt(DecimalData dec)
static long	DecimalDataUtils.castToIntegral(DecimalData dec)
static long	DecimalDataUtils.castToLong(DecimalData dec)
static short	DecimalDataUtils.castToShort(DecimalData dec)
static long	DecimalDataUtils.castToTimestamp(DecimalData dec)
static DecimalData	DecimalDataUtils.ceil(DecimalData decimal)
static int	DecimalDataUtils.compare(DecimalData b1, DecimalData b2)
static int	DecimalDataUtils.compare(DecimalData b1, double n2)
static int	DecimalDataUtils.compare(DecimalData b1, long n2)
static int	DecimalDataUtils.compare(double n1, DecimalData b2)
static int	DecimalDataUtils.compare(long n1, DecimalData b2)
int	DecimalData.compareTo(DecimalData that)
static DecimalData	DecimalDataUtils.divide(DecimalData v1, DecimalData v2, int precision, int scale)
static DecimalData	DecimalDataUtils.divideToIntegralValue(DecimalData value, DecimalData divisor, int precision, int scale) Returns a DecimalData whose value is the integer part of the quotient (this / divisor) rounded down.
static double	DecimalDataUtils.doubleValue(DecimalData decimal)
static DecimalData	DecimalDataUtils.floor(DecimalData decimal)
static DecimalData	DecimalDataUtils.mod(DecimalData v1, DecimalData v2, int precision, int scale)
static DecimalData	DecimalDataUtils.multiply(DecimalData v1, DecimalData v2, int precision, int scale)
static DecimalData	DecimalDataUtils.negate(DecimalData decimal)
void	ColumnarRowData.setDecimal(int pos, DecimalData value, int precision)
void	ColumnarArrayData.setDecimal(int pos, DecimalData value, int precision)
void	BoxedWrapperRowData.setDecimal(int pos, DecimalData value, int precision)
void	UpdatableRowData.setDecimal(int pos, DecimalData value, int precision)
static DecimalData	DecimalDataUtils.sign(DecimalData b0) SQL SIGN operator applied to BigDecimal values.
static int	DecimalDataUtils.signum(DecimalData decimal) Returns the signum function of this decimal.
static DecimalData	DecimalDataUtils.sround(DecimalData b0, int r) SQL ROUND operator applied to BigDecimal values.
static DecimalData	DecimalDataUtils.subtract(DecimalData v1, DecimalData v2, int precision, int scale)

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

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

Modifier and Type	Method and Description
DecimalData	BinaryRowData.getDecimal(int pos, int precision, int scale)
DecimalData	BinaryArrayData.getDecimal(int pos, int precision, int scale)
DecimalData	NestedRowData.getDecimal(int pos, int precision, int scale)
static DecimalData	BinarySegmentUtils.readDecimalData(MemorySegment[] segments, int baseOffset, long offsetAndSize, int precision, int scale) Gets an instance of DecimalData from underlying MemorySegment.
static DecimalData	BinaryStringDataUtil.toDecimal(BinaryStringData str, int precision, int scale) Parses this BinaryStringData to DecimalData.

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

Modifier and Type	Method and Description
void	BinaryRowData.setDecimal(int pos, DecimalData value, int precision)
void	BinaryArrayData.setDecimal(int pos, DecimalData value, int precision)
void	TypedSetters.setDecimal(int pos, DecimalData value, int precision) Set the decimal column value.
void	NestedRowData.setDecimal(int pos, DecimalData value, int precision)

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

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

Modifier and Type	Method and Description
DecimalData	DecimalBigDecimalConverter.toInternal(BigDecimal external)

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

Modifier and Type	Method and Description
BigDecimal	DecimalBigDecimalConverter.toExternal(DecimalData internal)

Uses of DecimalData in org.apache.flink.table.data.vector

Methods in org.apache.flink.table.data.vector that return DecimalData

Modifier and Type	Method and Description
DecimalData	DecimalColumnVector.getDecimal(int i, int precision, int scale)
DecimalData	VectorizedColumnBatch.getDecimal(int rowId, int colId, int precision, int scale)

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

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

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

Uses of DecimalData in org.apache.flink.table.planner.functions.aggfunctions

Methods in org.apache.flink.table.planner.functions.aggfunctions that return types with arguments of type DecimalData

Modifier and Type	Method and Description
protected TypeSerializer<DecimalData>	FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction.createValueSerializer()
protected TypeSerializer<DecimalData>	LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction.createValueSerializer()
TypeInformation<DecimalData>	FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction.getResultType()
TypeInformation<DecimalData>	LastValueAggFunction.DecimalLastValueAggFunction.getResultType()
TypeInformation<DecimalData>	FirstValueAggFunction.DecimalFirstValueAggFunction.getResultType()
TypeInformation<DecimalData>	LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction.getResultType()
protected TypeInformation<DecimalData>	MinWithRetractAggFunction.DecimalMinWithRetractAggFunction.getValueTypeInfo()
protected TypeInformation<DecimalData>	MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction.getValueTypeInfo()

Methods in org.apache.flink.table.planner.functions.aggfunctions with parameters of type DecimalData

Modifier and Type	Method and Description
void	FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction.accumulate(GenericRowData acc, DecimalData value)
void	LastValueAggFunction.DecimalLastValueAggFunction.accumulate(GenericRowData acc, DecimalData value)
void	FirstValueAggFunction.DecimalFirstValueAggFunction.accumulate(GenericRowData acc, DecimalData value)
void	LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction.accumulate(GenericRowData acc, DecimalData value)
void	FirstValueWithRetractAggFunction.DecimalFirstValueWithRetractAggFunction.accumulate(GenericRowData acc, DecimalData value, Long order)
void	LastValueAggFunction.DecimalLastValueAggFunction.accumulate(GenericRowData acc, DecimalData value, Long order)
void	FirstValueAggFunction.DecimalFirstValueAggFunction.accumulate(GenericRowData acc, DecimalData value, Long order)
void	LastValueWithRetractAggFunction.DecimalLastValueWithRetractAggFunction.accumulate(GenericRowData acc, DecimalData value, Long order)
void	MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction.accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<DecimalData> acc, DecimalData value)
void	MinWithRetractAggFunction.DecimalMinWithRetractAggFunction.accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<DecimalData> acc, DecimalData value)
void	MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction.retract(MaxWithRetractAggFunction.MaxWithRetractAccumulator<DecimalData> acc, DecimalData value)
void	MinWithRetractAggFunction.DecimalMinWithRetractAggFunction.retract(MinWithRetractAggFunction.MinWithRetractAccumulator<DecimalData> acc, DecimalData value)

Method parameters in org.apache.flink.table.planner.functions.aggfunctions with type arguments of type DecimalData

Modifier and Type	Method and Description
void	MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction.accumulate(MaxWithRetractAggFunction.MaxWithRetractAccumulator<DecimalData> acc, DecimalData value)
void	MinWithRetractAggFunction.DecimalMinWithRetractAggFunction.accumulate(MinWithRetractAggFunction.MinWithRetractAccumulator<DecimalData> acc, DecimalData value)
void	MaxWithRetractAggFunction.DecimalMaxWithRetractAggFunction.retract(MaxWithRetractAggFunction.MaxWithRetractAccumulator<DecimalData> acc, DecimalData value)
void	MinWithRetractAggFunction.DecimalMinWithRetractAggFunction.retract(MinWithRetractAggFunction.MinWithRetractAccumulator<DecimalData> acc, DecimalData value)

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

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

Modifier and Type	Method and Description
DecimalData	ArrowDecimalColumnVector.getDecimal(int i, int precision, int scale)

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

Methods in org.apache.flink.table.runtime.functions that return DecimalData

Modifier and Type	Method and Description
static DecimalData	SqlFunctionUtils.abs(DecimalData a)
static DecimalData	SqlFunctionUtils.ceil(DecimalData a)
static DecimalData	SqlFunctionUtils.floor(DecimalData a)
static DecimalData	SqlFunctionUtils.sign(DecimalData b0)
static DecimalData	SqlFunctionUtils.sround(DecimalData b0) SQL ROUND operator applied to DecimalData values.
static DecimalData	SqlFunctionUtils.sround(DecimalData b0, int b1) SQL ROUND operator applied to DecimalData values.
static DecimalData	SqlFunctionUtils.struncate(DecimalData b0) SQL TRUNCATE operator applied to BigDecimal values.
static DecimalData	SqlFunctionUtils.struncate(DecimalData b0, int b1)

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

Modifier and Type	Method and Description
static DecimalData	SqlFunctionUtils.abs(DecimalData a)
static double	SqlFunctionUtils.acos(DecimalData a)
static double	SqlFunctionUtils.asin(DecimalData a)
static double	SqlFunctionUtils.atan(DecimalData a)
static double	SqlFunctionUtils.atan2(DecimalData y, DecimalData x)
static DecimalData	SqlFunctionUtils.ceil(DecimalData a)
static double	SqlFunctionUtils.cos(DecimalData a)
static double	SqlFunctionUtils.cosh(DecimalData x)
static double	SqlFunctionUtils.cot(DecimalData a)
static double	SqlFunctionUtils.degrees(DecimalData angrad)
static double	SqlFunctionUtils.exp(DecimalData d)
static DecimalData	SqlFunctionUtils.floor(DecimalData a)
static String	SqlDateTimeUtils.fromUnixtime(DecimalData unixtime)
static String	SqlDateTimeUtils.fromUnixtime(DecimalData unixtime, TimeZone tz)
static double	SqlFunctionUtils.log(DecimalData x)
static double	SqlFunctionUtils.log(DecimalData base, DecimalData x)
static double	SqlFunctionUtils.log(DecimalData base, double x)
static double	SqlFunctionUtils.log(double base, DecimalData x)
static double	SqlFunctionUtils.log10(DecimalData x)
static double	SqlFunctionUtils.log2(DecimalData x)
static double	SqlFunctionUtils.power(DecimalData base, DecimalData exponent)
static double	SqlFunctionUtils.power(DecimalData base, double exponent)
static double	SqlFunctionUtils.power(double base, DecimalData exponent)
static double	SqlFunctionUtils.radians(DecimalData angdeg)
static DecimalData	SqlFunctionUtils.sign(DecimalData b0)
static double	SqlFunctionUtils.sin(DecimalData a)
static double	SqlFunctionUtils.sinh(DecimalData a)
static DecimalData	SqlFunctionUtils.sround(DecimalData b0) SQL ROUND operator applied to DecimalData values.
static DecimalData	SqlFunctionUtils.sround(DecimalData b0, int b1) SQL ROUND operator applied to DecimalData values.
static DecimalData	SqlFunctionUtils.struncate(DecimalData b0) SQL TRUNCATE operator applied to BigDecimal values.
static DecimalData	SqlFunctionUtils.struncate(DecimalData b0, int b1)
static double	SqlFunctionUtils.tan(DecimalData a)
static double	SqlFunctionUtils.tanh(DecimalData a) Calculates the hyperbolic tangent of a big decimal number.
static long	SqlDateTimeUtils.toTimestamp(DecimalData v)

Uses of DecimalData in org.apache.flink.table.runtime.operators.sort

Methods in org.apache.flink.table.runtime.operators.sort with parameters of type DecimalData

Modifier and Type	Method and Description
static void	SortUtil.putDecimalNormalizedKey(DecimalData record, MemorySegment target, int offset, int len) Just support the compact precision decimal.

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

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

Modifier and Type	Method and Description
DecimalData	DecimalDataSerializer.copy(DecimalData from)
DecimalData	DecimalDataSerializer.copy(DecimalData from, DecimalData reuse)
DecimalData	DecimalDataSerializer.createInstance()
DecimalData	DecimalDataSerializer.deserialize(DataInputView source)
DecimalData	DecimalDataSerializer.deserialize(DecimalData record, DataInputView source)

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

Modifier and Type	Method and Description
TypeSerializer<DecimalData>	DecimalDataTypeInfo.createSerializer(ExecutionConfig config)
Class<DecimalData>	DecimalDataTypeInfo.getTypeClass()
TypeSerializerSchemaCompatibility<DecimalData>	DecimalDataSerializer.DecimalSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<DecimalData> newSerializer)
TypeSerializer<DecimalData>	DecimalDataSerializer.DecimalSerializerSnapshot.restoreSerializer()
TypeSerializerSnapshot<DecimalData>	DecimalDataSerializer.snapshotConfiguration()

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

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

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

Modifier and Type	Method and Description
TypeSerializerSchemaCompatibility<DecimalData>	DecimalDataSerializer.DecimalSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<DecimalData> newSerializer)

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

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

Modifier and Type	Method and Description
DecimalData	DecimalDataSerializer.copy(DecimalData from)
DecimalData	DecimalDataSerializer.copy(DecimalData from, DecimalData reuse)
DecimalData	DecimalDataSerializer.createInstance()
DecimalData	DecimalDataSerializer.deserialize(DataInputView source)
DecimalData	DecimalDataSerializer.deserialize(DecimalData reuse, DataInputView source)

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

Modifier and Type	Method and Description
TypeSerializer<DecimalData>	DecimalDataSerializer.duplicate()
TypeSerializerSchemaCompatibility<DecimalData>	DecimalDataSerializer.DecimalSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<DecimalData> newSerializer)
TypeSerializer<DecimalData>	DecimalDataSerializer.DecimalSerializerSnapshot.restoreSerializer()
TypeSerializerSnapshot<DecimalData>	DecimalDataSerializer.snapshotConfiguration()

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

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

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

Modifier and Type	Method and Description
TypeSerializerSchemaCompatibility<DecimalData>	DecimalDataSerializer.DecimalSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<DecimalData> newSerializer)