Package org.apache.flink.table.data

Class DecimalDataUtils

java.lang.Object

org.apache.flink.table.data.DecimalDataUtils

public final class DecimalDataUtils
extends Object

Utilities for DecimalData.

Note: we have to put this class under the same package with DecimalData to make it possible to access package-accessing member variables.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.table.types.logical.DecimalType	DECIMAL_SYSTEM_DEFAULT

Constructor Summary

Constructors

Constructor	Description
DecimalDataUtils()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.table.data.DecimalData	abs(org.apache.flink.table.data.DecimalData decimal)
static org.apache.flink.table.data.DecimalData	add(org.apache.flink.table.data.DecimalData v1, org.apache.flink.table.data.DecimalData v2, int precision, int scale)
static org.apache.flink.table.data.DecimalData	castFrom(double val, int p, int s)
static org.apache.flink.table.data.DecimalData	castFrom(long val, int p, int s)
static org.apache.flink.table.data.DecimalData	castFrom(String string, int precision, int scale)
static org.apache.flink.table.data.DecimalData	castFrom(org.apache.flink.table.data.DecimalData dec, int precision, int scale)
static boolean	castToBoolean(org.apache.flink.table.data.DecimalData dec)
static org.apache.flink.table.data.DecimalData	castToDecimal(org.apache.flink.table.data.DecimalData dec, int precision, int scale)
static long	castToIntegral(org.apache.flink.table.data.DecimalData dec)
static org.apache.flink.table.data.DecimalData	ceil(org.apache.flink.table.data.DecimalData decimal)
static int	compare(double n1, org.apache.flink.table.data.DecimalData b2)
static int	compare(long n1, org.apache.flink.table.data.DecimalData b2)
static int	compare(org.apache.flink.table.data.DecimalData b1, double n2)
static int	compare(org.apache.flink.table.data.DecimalData b1, long n2)
static int	compare(org.apache.flink.table.data.DecimalData b1, org.apache.flink.table.data.DecimalData b2)
static org.apache.flink.table.data.DecimalData	divide(org.apache.flink.table.data.DecimalData v1, org.apache.flink.table.data.DecimalData v2, int precision, int scale)
static org.apache.flink.table.data.DecimalData	divideToIntegralValue(org.apache.flink.table.data.DecimalData value, org.apache.flink.table.data.DecimalData divisor, int precision, int scale)	Returns a DecimalData whose value is the integer part of the quotient (this / divisor) rounded down.
static double	doubleValue(org.apache.flink.table.data.DecimalData decimal)
static org.apache.flink.table.data.DecimalData	floor(org.apache.flink.table.data.DecimalData decimal)
static boolean	is32BitDecimal(int precision)
static boolean	is64BitDecimal(int precision)
static boolean	isByteArrayDecimal(int precision)
static org.apache.flink.table.data.DecimalData	mod(org.apache.flink.table.data.DecimalData v1, org.apache.flink.table.data.DecimalData v2, int precision, int scale)
static org.apache.flink.table.data.DecimalData	multiply(org.apache.flink.table.data.DecimalData v1, org.apache.flink.table.data.DecimalData v2, int precision, int scale)
static org.apache.flink.table.data.DecimalData	negate(org.apache.flink.table.data.DecimalData decimal)
static long	power10(int n)
static org.apache.flink.table.data.DecimalData	sign(org.apache.flink.table.data.DecimalData b0)	SQL SIGN operator applied to BigDecimal values. preserve precision and scale.
static int	signum(org.apache.flink.table.data.DecimalData decimal)	Returns the signum function of this decimal.
static org.apache.flink.table.data.DecimalData	sround(org.apache.flink.table.data.DecimalData b0, int r)	SQL ROUND operator applied to BigDecimal values.
static org.apache.flink.table.data.DecimalData	subtract(org.apache.flink.table.data.DecimalData v1, org.apache.flink.table.data.DecimalData v2, int precision, int scale)

Methods inherited from class java.lang.Object

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

Field Detail

DECIMAL_SYSTEM_DEFAULT

public static final org.apache.flink.table.types.logical.DecimalType DECIMAL_SYSTEM_DEFAULT

Constructor Detail

DecimalDataUtils

public DecimalDataUtils()

Method Detail

doubleValue

public static double doubleValue(org.apache.flink.table.data.DecimalData decimal)

signum

public static int signum(org.apache.flink.table.data.DecimalData decimal)

Returns the signum function of this decimal. (The return value is -1 if this decimal is negative; 0 if this decimal is zero; and 1 if this decimal is positive.)

Returns:

the signum function of this decimal.

negate

public static org.apache.flink.table.data.DecimalData negate(org.apache.flink.table.data.DecimalData decimal)

abs

public static org.apache.flink.table.data.DecimalData abs(org.apache.flink.table.data.DecimalData decimal)

floor

public static org.apache.flink.table.data.DecimalData floor(org.apache.flink.table.data.DecimalData decimal)

ceil

public static org.apache.flink.table.data.DecimalData ceil(org.apache.flink.table.data.DecimalData decimal)

add

public static org.apache.flink.table.data.DecimalData add(org.apache.flink.table.data.DecimalData v1,
                                                          org.apache.flink.table.data.DecimalData v2,
                                                          int precision,
                                                          int scale)

subtract

public static org.apache.flink.table.data.DecimalData subtract(org.apache.flink.table.data.DecimalData v1,
                                                               org.apache.flink.table.data.DecimalData v2,
                                                               int precision,
                                                               int scale)

multiply

public static org.apache.flink.table.data.DecimalData multiply(org.apache.flink.table.data.DecimalData v1,
                                                               org.apache.flink.table.data.DecimalData v2,
                                                               int precision,
                                                               int scale)

divide

public static org.apache.flink.table.data.DecimalData divide(org.apache.flink.table.data.DecimalData v1,
                                                             org.apache.flink.table.data.DecimalData v2,
                                                             int precision,
                                                             int scale)

mod

public static org.apache.flink.table.data.DecimalData mod(org.apache.flink.table.data.DecimalData v1,
                                                          org.apache.flink.table.data.DecimalData v2,
                                                          int precision,
                                                          int scale)

divideToIntegralValue

public static org.apache.flink.table.data.DecimalData divideToIntegralValue(org.apache.flink.table.data.DecimalData value,
                                                                            org.apache.flink.table.data.DecimalData divisor,
                                                                            int precision,
                                                                            int scale)

Returns a DecimalData whose value is the integer part of the quotient (this / divisor) rounded down.

Parameters:

value - value by which this DecimalData is to be divided.

divisor - value by which this DecimalData is to be divided.

Returns:

The integer part of this / divisor.

Throws:

ArithmeticException - if divisor==0

castToIntegral

public static long castToIntegral(org.apache.flink.table.data.DecimalData dec)

castToDecimal

public static org.apache.flink.table.data.DecimalData castToDecimal(org.apache.flink.table.data.DecimalData dec,
                                                                    int precision,
                                                                    int scale)

castFrom

public static org.apache.flink.table.data.DecimalData castFrom(org.apache.flink.table.data.DecimalData dec,
                                                               int precision,
                                                               int scale)

castFrom

public static org.apache.flink.table.data.DecimalData castFrom(String string,
                                                               int precision,
                                                               int scale)

castFrom

public static org.apache.flink.table.data.DecimalData castFrom(double val,
                                                               int p,
                                                               int s)

castFrom

public static org.apache.flink.table.data.DecimalData castFrom(long val,
                                                               int p,
                                                               int s)

castToBoolean

public static boolean castToBoolean(org.apache.flink.table.data.DecimalData dec)

sign

public static org.apache.flink.table.data.DecimalData sign(org.apache.flink.table.data.DecimalData b0)

SQL SIGN operator applied to BigDecimal values. preserve precision and scale.

compare

public static int compare(org.apache.flink.table.data.DecimalData b1,
                          org.apache.flink.table.data.DecimalData b2)

compare

public static int compare(org.apache.flink.table.data.DecimalData b1,
                          long n2)

compare

public static int compare(org.apache.flink.table.data.DecimalData b1,
                          double n2)

compare

public static int compare(long n1,
                          org.apache.flink.table.data.DecimalData b2)

compare

public static int compare(double n1,
                          org.apache.flink.table.data.DecimalData b2)

sround

public static org.apache.flink.table.data.DecimalData sround(org.apache.flink.table.data.DecimalData b0,
                                                             int r)

SQL ROUND operator applied to BigDecimal values.

power10

public static long power10(int n)

is32BitDecimal

public static boolean is32BitDecimal(int precision)

is64BitDecimal

public static boolean is64BitDecimal(int precision)

isByteArrayDecimal

public static boolean isByteArrayDecimal(int precision)