org.apache.flink.table.runtime.types

Class PlannerTypeUtils

java.lang.Object

org.apache.flink.table.runtime.types.PlannerTypeUtils

public class PlannerTypeUtils
extends Object

Utilities for LogicalType and DataType..

Constructor Summary

Constructors

Constructor and Description
PlannerTypeUtils()

Method Summary

Modifier and Type	Method and Description
static boolean	isAssignable(LogicalType t1, LogicalType t2) Now in the conversion to the TypeInformation from DataType, type may lose some information about nullable and precision.
static boolean	isInteroperable(LogicalType t1, LogicalType t2) Can the two types operate with each other.
static boolean	isPrimitive(LogicalType type)
static boolean	isPrimitive(LogicalTypeRoot root)
static LogicalType	removeLegacyTypes(LogicalType t) A conversion that removes all LegacyTypeInformationTypes by mapping to corresponding new types.

Methods inherited from class java.lang.Object

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

Constructor Detail

PlannerTypeUtils

public PlannerTypeUtils()

Method Detail

removeLegacyTypes

public static LogicalType removeLegacyTypes(LogicalType t)

A conversion that removes all LegacyTypeInformationTypes by mapping to corresponding new types.

isPrimitive

public static boolean isPrimitive(LogicalType type)

isPrimitive

public static boolean isPrimitive(LogicalTypeRoot root)

isInteroperable

public static boolean isInteroperable(LogicalType t1,
                                      LogicalType t2)

Can the two types operate with each other. Such as: 1.CodeGen: equal, cast, assignment. 2.Join keys.

isAssignable

public static boolean isAssignable(LogicalType t1,
                                   LogicalType t2)

Now in the conversion to the TypeInformation from DataType, type may lose some information about nullable and precision. So we add this method to do a soft check.

The difference of isInteroperable(org.apache.flink.table.types.logical.LogicalType, org.apache.flink.table.types.logical.LogicalType) is ignore precisions.