public class FlinkTypeFactory
extends org.apache.calcite.jdbc.JavaTypeFactoryImpl
TypeInformation
and Calcite's RelDataType
.org.apache.calcite.jdbc.JavaTypeFactoryImpl.SyntheticRecordType
Constructor and Description |
---|
FlinkTypeFactory(org.apache.calcite.rel.type.RelDataTypeSystem typeSystem) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.type.RelDataTypeFactory.FieldInfoBuilder |
builder() |
org.apache.calcite.rel.type.RelDataType |
buildLogicalRowType(scala.collection.Seq<String> fieldNames,
scala.collection.Seq<TypeInformation<?>> fieldTypes,
scala.Option<scala.Tuple2<Object,String>> rowtime,
scala.Option<scala.Tuple2<Object,String>> proctime)
Creates a struct type with the input fieldNames and input fieldTypes using FlinkTypeFactory
|
protected static org.apache.calcite.rel.type.RelDataType |
canonize(org.apache.calcite.rel.type.RelDataType x$1) |
protected static org.apache.calcite.rel.type.RelDataType |
canonize(org.apache.calcite.rel.type.StructKind x$1,
List<String> x$2,
List<org.apache.calcite.rel.type.RelDataType> x$3) |
static org.apache.calcite.rel.type.RelDataType |
copyType(org.apache.calcite.rel.type.RelDataType x$1) |
org.apache.calcite.rel.type.RelDataType |
createArrayType(org.apache.calcite.rel.type.RelDataType elementType,
long maxCardinality) |
static org.apache.calcite.rel.type.RelDataType |
createDecimalProduct(org.apache.calcite.rel.type.RelDataType x$1,
org.apache.calcite.rel.type.RelDataType x$2) |
static org.apache.calcite.rel.type.RelDataType |
createDecimalQuotient(org.apache.calcite.rel.type.RelDataType x$1,
org.apache.calcite.rel.type.RelDataType x$2) |
static org.apache.calcite.rel.type.RelDataType |
createJavaType(Class<?> x$1) |
static org.apache.calcite.rel.type.RelDataType |
createJoinType(org.apache.calcite.rel.type.RelDataType[] x$1) |
static org.apache.calcite.rel.type.RelDataType |
createMapType(org.apache.calcite.rel.type.RelDataType x$1,
org.apache.calcite.rel.type.RelDataType x$2) |
static org.apache.calcite.rel.type.RelDataType |
createMultisetType(org.apache.calcite.rel.type.RelDataType x$1,
long x$2) |
org.apache.calcite.rel.type.RelDataType |
createProctimeIndicatorType()
Creates a indicator type for processing-time, but with similar properties as SQL timestamp.
|
org.apache.calcite.rel.type.RelDataType |
createRowtimeIndicatorType()
Creates a indicator type for event-time, but with similar properties as SQL timestamp.
|
static org.apache.calcite.rel.type.RelDataType |
createSqlIntervalType(org.apache.calcite.sql.SqlIntervalQualifier x$1) |
org.apache.calcite.rel.type.RelDataType |
createSqlType(org.apache.calcite.sql.type.SqlTypeName typeName,
int precision) |
static org.apache.calcite.rel.type.RelDataType |
createStructType(Class<?> x$1) |
static org.apache.calcite.rel.type.RelDataType |
createStructType(List<? extends Map.Entry<String,org.apache.calcite.rel.type.RelDataType>> x$1) |
static org.apache.calcite.rel.type.RelDataType |
createStructType(List<org.apache.calcite.rel.type.RelDataType> x$1,
List<String> x$2) |
static org.apache.calcite.rel.type.RelDataType |
createStructType(org.apache.calcite.rel.type.RelDataTypeFactory.FieldInfo x$1) |
static org.apache.calcite.rel.type.RelDataType |
createStructType(org.apache.calcite.rel.type.StructKind x$1,
List<org.apache.calcite.rel.type.RelDataType> x$2,
List<String> x$3) |
static Type |
createSyntheticType(List<Type> x$1) |
static org.apache.calcite.rel.type.RelDataType |
createType(Type x$1) |
org.apache.calcite.rel.type.RelDataType |
createTypeFromTypeInfo(TypeInformation<?> typeInfo,
boolean isNullable) |
static org.apache.calcite.rel.type.RelDataType |
createTypeWithCharsetAndCollation(org.apache.calcite.rel.type.RelDataType x$1,
Charset x$2,
org.apache.calcite.sql.SqlCollation x$3) |
org.apache.calcite.rel.type.RelDataType |
createTypeWithNullability(org.apache.calcite.rel.type.RelDataType relDataType,
boolean isNullable) |
static Charset |
getDefaultCharset() |
static Type |
getJavaClass(org.apache.calcite.rel.type.RelDataType x$1) |
static org.apache.calcite.rel.type.RelDataTypeSystem |
getTypeSystem() |
static boolean |
isProctimeIndicatorType(org.apache.calcite.rel.type.RelDataType relDataType) |
static boolean |
isProctimeIndicatorType(TypeInformation<?> typeInfo) |
static boolean |
isRowtimeIndicatorType(org.apache.calcite.rel.type.RelDataType relDataType) |
static boolean |
isRowtimeIndicatorType(TypeInformation<?> typeInfo) |
static boolean |
isTimeIndicatorType(org.apache.calcite.rel.type.RelDataType relDataType) |
static boolean |
isTimeIndicatorType(TypeInformation<?> typeInfo) |
org.apache.calcite.rel.type.RelDataType |
leastRestrictive(List<org.apache.calcite.rel.type.RelDataType> types) |
protected static org.apache.calcite.rel.type.RelDataType |
leastRestrictiveStructuredType(List<org.apache.calcite.rel.type.RelDataType> x$1) |
protected static boolean |
shouldRaggedFixedLengthValueUnionBeVariable() |
static TypeInformation<Row> |
toInternalRowTypeInfo(org.apache.calcite.rel.type.RelDataType logicalRowType)
Deprecated.
Use the RowSchema class instead because it handles both logical and physical rows. Since .
|
static org.apache.calcite.rel.type.RelDataType |
toSql(org.apache.calcite.rel.type.RelDataType x$1) |
static TypeInformation<?> |
toTypeInfo(org.apache.calcite.rel.type.RelDataType relDataType) |
static boolean |
useDoubleMultiplication(org.apache.calcite.rel.type.RelDataType x$1,
org.apache.calcite.rel.type.RelDataType x$2) |
createStructType, createSyntheticType, createType, getJavaClass, toSql, toSql
canonize, createMapType, createMultisetType, createSqlIntervalType, createSqlType, createSqlType, createTypeWithCharsetAndCollation, shouldRaggedFixedLengthValueUnionBeVariable
builder, canonize, copyType, createDecimalProduct, createDecimalQuotient, createJavaType, createJoinType, createStructType, createStructType, createStructType, createStructType, getDefaultCharset, getTypeSystem, isJavaType, leastRestrictiveStructuredType, useDoubleMultiplication
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
builder, copyType, createDecimalProduct, createDecimalQuotient, createJavaType, createJoinType, createMapType, createMultisetType, createSqlIntervalType, createSqlType, createSqlType, createStructType, createStructType, createStructType, createStructType, createTypeWithCharsetAndCollation, getDefaultCharset, getTypeSystem, useDoubleMultiplication
public FlinkTypeFactory(org.apache.calcite.rel.type.RelDataTypeSystem typeSystem)
public static TypeInformation<Row> toInternalRowTypeInfo(org.apache.calcite.rel.type.RelDataType logicalRowType)
logicalRowType
- (undocumented)public static boolean isProctimeIndicatorType(org.apache.calcite.rel.type.RelDataType relDataType)
public static boolean isProctimeIndicatorType(TypeInformation<?> typeInfo)
public static boolean isRowtimeIndicatorType(org.apache.calcite.rel.type.RelDataType relDataType)
public static boolean isRowtimeIndicatorType(TypeInformation<?> typeInfo)
public static boolean isTimeIndicatorType(org.apache.calcite.rel.type.RelDataType relDataType)
public static boolean isTimeIndicatorType(TypeInformation<?> typeInfo)
public static TypeInformation<?> toTypeInfo(org.apache.calcite.rel.type.RelDataType relDataType)
public static org.apache.calcite.rel.type.RelDataTypeSystem getTypeSystem()
public static org.apache.calcite.rel.type.RelDataType createJavaType(Class<?> x$1)
public static org.apache.calcite.rel.type.RelDataType createJoinType(org.apache.calcite.rel.type.RelDataType[] x$1)
public static org.apache.calcite.rel.type.RelDataType createStructType(List<org.apache.calcite.rel.type.RelDataType> x$1, List<String> x$2)
public static org.apache.calcite.rel.type.RelDataType createStructType(org.apache.calcite.rel.type.StructKind x$1, List<org.apache.calcite.rel.type.RelDataType> x$2, List<String> x$3)
public static org.apache.calcite.rel.type.RelDataType createStructType(org.apache.calcite.rel.type.RelDataTypeFactory.FieldInfo x$1)
public static final org.apache.calcite.rel.type.RelDataType createStructType(List<? extends Map.Entry<String,org.apache.calcite.rel.type.RelDataType>> x$1)
protected static org.apache.calcite.rel.type.RelDataType leastRestrictiveStructuredType(List<org.apache.calcite.rel.type.RelDataType> x$1)
public static org.apache.calcite.rel.type.RelDataType copyType(org.apache.calcite.rel.type.RelDataType x$1)
protected static org.apache.calcite.rel.type.RelDataType canonize(org.apache.calcite.rel.type.StructKind x$1, List<String> x$2, List<org.apache.calcite.rel.type.RelDataType> x$3)
public static org.apache.calcite.rel.type.RelDataType createDecimalProduct(org.apache.calcite.rel.type.RelDataType x$1, org.apache.calcite.rel.type.RelDataType x$2)
public static boolean useDoubleMultiplication(org.apache.calcite.rel.type.RelDataType x$1, org.apache.calcite.rel.type.RelDataType x$2)
public static org.apache.calcite.rel.type.RelDataType createDecimalQuotient(org.apache.calcite.rel.type.RelDataType x$1, org.apache.calcite.rel.type.RelDataType x$2)
public static Charset getDefaultCharset()
public static org.apache.calcite.rel.type.RelDataTypeFactory.FieldInfoBuilder builder()
public static org.apache.calcite.rel.type.RelDataType createMultisetType(org.apache.calcite.rel.type.RelDataType x$1, long x$2)
public static org.apache.calcite.rel.type.RelDataType createMapType(org.apache.calcite.rel.type.RelDataType x$1, org.apache.calcite.rel.type.RelDataType x$2)
public static org.apache.calcite.rel.type.RelDataType createSqlIntervalType(org.apache.calcite.sql.SqlIntervalQualifier x$1)
public static org.apache.calcite.rel.type.RelDataType createTypeWithCharsetAndCollation(org.apache.calcite.rel.type.RelDataType x$1, Charset x$2, org.apache.calcite.sql.SqlCollation x$3)
protected static boolean shouldRaggedFixedLengthValueUnionBeVariable()
protected static org.apache.calcite.rel.type.RelDataType canonize(org.apache.calcite.rel.type.RelDataType x$1)
public static org.apache.calcite.rel.type.RelDataType createStructType(Class<?> x$1)
public static org.apache.calcite.rel.type.RelDataType createType(Type x$1)
public static Type getJavaClass(org.apache.calcite.rel.type.RelDataType x$1)
public static org.apache.calcite.rel.type.RelDataType toSql(org.apache.calcite.rel.type.RelDataType x$1)
public org.apache.calcite.rel.type.RelDataType createTypeFromTypeInfo(TypeInformation<?> typeInfo, boolean isNullable)
public org.apache.calcite.rel.type.RelDataType createProctimeIndicatorType()
public org.apache.calcite.rel.type.RelDataType createRowtimeIndicatorType()
public org.apache.calcite.rel.type.RelDataType buildLogicalRowType(scala.collection.Seq<String> fieldNames, scala.collection.Seq<TypeInformation<?>> fieldTypes, scala.Option<scala.Tuple2<Object,String>> rowtime, scala.Option<scala.Tuple2<Object,String>> proctime)
fieldNames
- field namesfieldTypes
- field types, every element is Flink's TypeInformation
rowtime
- optional system field to indicate event-time; the index determines the index
in the final record. If the index is smaller than the number of specified
fields, it shifts all following fields.proctime
- optional system field to indicate processing-time; the index determines the
index in the final record. If the index is smaller than the number of
specified fields, it shifts all following fields.public org.apache.calcite.rel.type.RelDataType createSqlType(org.apache.calcite.sql.type.SqlTypeName typeName, int precision)
createSqlType
in interface org.apache.calcite.rel.type.RelDataTypeFactory
createSqlType
in class org.apache.calcite.sql.type.SqlTypeFactoryImpl
public org.apache.calcite.rel.type.RelDataType createArrayType(org.apache.calcite.rel.type.RelDataType elementType, long maxCardinality)
createArrayType
in interface org.apache.calcite.rel.type.RelDataTypeFactory
createArrayType
in class org.apache.calcite.sql.type.SqlTypeFactoryImpl
public org.apache.calcite.rel.type.RelDataType createTypeWithNullability(org.apache.calcite.rel.type.RelDataType relDataType, boolean isNullable)
createTypeWithNullability
in interface org.apache.calcite.rel.type.RelDataTypeFactory
createTypeWithNullability
in class org.apache.calcite.sql.type.SqlTypeFactoryImpl
public org.apache.calcite.rel.type.RelDataType leastRestrictive(List<org.apache.calcite.rel.type.RelDataType> types)
leastRestrictive
in interface org.apache.calcite.rel.type.RelDataTypeFactory
leastRestrictive
in class org.apache.calcite.sql.type.SqlTypeFactoryImpl
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.