public class TypeConverter$ extends Object
Modifier and Type | Field and Description |
---|---|
static TypeConverter$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
TypeConverter$() |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Object> |
DEFAULT_ROW_TYPE() |
TypeInformation<Object> |
determineReturnType(org.apache.calcite.rel.type.RelDataType logicalRowType,
scala.Option<TypeInformation<Object>> expectedPhysicalType,
boolean nullable,
boolean useEfficientTypes)
Determines the return type of Flink operators based on the logical fields, the expected
physical type and configuration parameters.
|
org.apache.calcite.rel.core.JoinRelType |
flinkJoinTypeToRelType(JoinType joinType) |
JoinType |
sqlJoinTypeToFlinkJoinType(org.apache.calcite.rel.core.JoinRelType sqlJoinType) |
public static final TypeConverter$ MODULE$
public TypeInformation<Object> DEFAULT_ROW_TYPE()
public TypeInformation<Object> determineReturnType(org.apache.calcite.rel.type.RelDataType logicalRowType, scala.Option<TypeInformation<Object>> expectedPhysicalType, boolean nullable, boolean useEfficientTypes)
For example: - No physical type expected, only 3 non-null fields and efficient type usage enabled -> return Tuple3 - No physical type expected, efficient type usage enabled, but 3 nullable fields -> return Row because Tuple does not support null values - Physical type expected -> check if physical type is compatible and return it
logicalRowType
- logical row informationexpectedPhysicalType
- expected physical typenullable
- fields can be nullableuseEfficientTypes
- use the most efficient types (e.g. Tuples and value types)public JoinType sqlJoinTypeToFlinkJoinType(org.apache.calcite.rel.core.JoinRelType sqlJoinType)
public org.apache.calcite.rel.core.JoinRelType flinkJoinTypeToRelType(JoinType joinType)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.