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 int	getArity(LogicalType t) Gets the arity of the type.
static boolean	isAssignable(LogicalType t1, LogicalType t2) Now in the conversion to the TypeInformation from DataType, type may loose 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 RowType	toRowType(LogicalType t)

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

getArity

public static int getArity(LogicalType t)

Gets the arity of the type.

toRowType

public static RowType toRowType(LogicalType t)

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 loose 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.