Package org.apache.flink.table.runtime.typeutils

Class DecimalDataTypeInfo

java.lang.Object

org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

org.apache.flink.table.runtime.typeutils.DecimalDataTypeInfo

All Implemented Interfaces:

Serializable, org.apache.flink.table.types.DataTypeQueryable

@Internal
public class DecimalDataTypeInfo
extends org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>
implements org.apache.flink.table.types.DataTypeQueryable

TypeInformation for DecimalData.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DecimalDataTypeInfo(int precision, int scale)

Method Summary

Modifier and Type	Method	Description
boolean	canEqual(Object obj)
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.DecimalData>	createSerializer(org.apache.flink.api.common.ExecutionConfig config)
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.DecimalData>	createSerializer(org.apache.flink.api.common.serialization.SerializerConfig config)
boolean	equals(Object obj)
int	getArity()
org.apache.flink.table.types.DataType	getDataType()
int	getTotalFields()
Class<org.apache.flink.table.data.DecimalData>	getTypeClass()
int	hashCode()
boolean	isBasicType()
boolean	isKeyType()
boolean	isTupleType()
static DecimalDataTypeInfo	of(int precision, int scale)
int	precision()
int	scale()
String	toString()

Methods inherited from class org.apache.flink.api.common.typeinfo.TypeInformation

getGenericParameters, isSortKeyType, of, of

Methods inherited from class java.lang.Object

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

Constructor Detail

DecimalDataTypeInfo

public DecimalDataTypeInfo(int precision,
                           int scale)

Method Detail

of

public static DecimalDataTypeInfo of(int precision,
                                     int scale)

getDataType

public org.apache.flink.table.types.DataType getDataType()

Specified by:

getDataType in interface org.apache.flink.table.types.DataTypeQueryable

isBasicType

public boolean isBasicType()

Specified by:

isBasicType in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

isTupleType

public boolean isTupleType()

Specified by:

isTupleType in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

getArity

public int getArity()

Specified by:

getArity in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

getTotalFields

public int getTotalFields()

Specified by:

getTotalFields in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

getTypeClass

public Class<org.apache.flink.table.data.DecimalData> getTypeClass()

Specified by:

getTypeClass in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

isKeyType

public boolean isKeyType()

Specified by:

isKeyType in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

createSerializer

public org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.DecimalData> createSerializer(org.apache.flink.api.common.serialization.SerializerConfig config)

Overrides:

createSerializer in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

createSerializer

public org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.DecimalData> createSerializer(org.apache.flink.api.common.ExecutionConfig config)

Specified by:

createSerializer in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

toString

public String toString()

Specified by:

toString in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

equals

public boolean equals(Object obj)

Specified by:

equals in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

hashCode

public int hashCode()

Specified by:

hashCode in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

canEqual

public boolean canEqual(Object obj)

Specified by:

canEqual in class org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.DecimalData>

precision

public int precision()

scale

public int scale()