Class DataTypePrecisionFixer
- java.lang.Object
-
- org.apache.flink.table.runtime.types.DataTypePrecisionFixer
-
- All Implemented Interfaces:
org.apache.flink.table.types.DataTypeVisitor<org.apache.flink.table.types.DataType>
public final class DataTypePrecisionFixer extends Object implements org.apache.flink.table.types.DataTypeVisitor<org.apache.flink.table.types.DataType>
The data type visitor used to fix the precision for data type with the given logical type which carries the correct precisions. The original data type may loses precision because of conversion fromTypeInformation.
-
-
Constructor Summary
Constructors Constructor Description DataTypePrecisionFixer(org.apache.flink.table.types.logical.LogicalType logicalType)Creates a new instance with the given logical type.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.table.types.DataTypevisit(org.apache.flink.table.types.AtomicDataType dataType)org.apache.flink.table.types.DataTypevisit(org.apache.flink.table.types.CollectionDataType collectionDataType)org.apache.flink.table.types.DataTypevisit(org.apache.flink.table.types.FieldsDataType fieldsDataType)org.apache.flink.table.types.DataTypevisit(org.apache.flink.table.types.KeyValueDataType keyValueDataType)
-
-
-
Method Detail
-
visit
public org.apache.flink.table.types.DataType visit(org.apache.flink.table.types.AtomicDataType dataType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.DataTypeVisitor<org.apache.flink.table.types.DataType>
-
visit
public org.apache.flink.table.types.DataType visit(org.apache.flink.table.types.CollectionDataType collectionDataType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.DataTypeVisitor<org.apache.flink.table.types.DataType>
-
visit
public org.apache.flink.table.types.DataType visit(org.apache.flink.table.types.FieldsDataType fieldsDataType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.DataTypeVisitor<org.apache.flink.table.types.DataType>
-
visit
public org.apache.flink.table.types.DataType visit(org.apache.flink.table.types.KeyValueDataType keyValueDataType)
- Specified by:
visitin interfaceorg.apache.flink.table.types.DataTypeVisitor<org.apache.flink.table.types.DataType>
-
-