public class TypeConverter extends Object
Constructor and Description |
---|
TypeConverter() |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<Object> |
DEFAULT_ROW_TYPE() |
static 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.
|
static org.apache.calcite.rel.core.JoinRelType |
flinkJoinTypeToRelType(JoinType joinType) |
static JoinType |
sqlJoinTypeToFlinkJoinType(org.apache.calcite.rel.core.JoinRelType sqlJoinType) |
public static TypeInformation<Object> DEFAULT_ROW_TYPE()
public static 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 static JoinType sqlJoinTypeToFlinkJoinType(org.apache.calcite.rel.core.JoinRelType sqlJoinType)
public static org.apache.calcite.rel.core.JoinRelType flinkJoinTypeToRelType(JoinType joinType)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.