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 |
---|---|
org.apache.calcite.rel.type.RelDataType |
createTypeFromTypeInfo(TypeInformation<?> typeInfo) |
static TypeInformation<?> |
toTypeInfo(org.apache.calcite.rel.type.RelDataType relDataType) |
createStructType, createSyntheticType, createType, getJavaClass, toSql
canonize, createArrayType, createMapType, createMultisetType, createSqlIntervalType, createSqlType, createSqlType, createSqlType, createTypeWithCharsetAndCollation, createTypeWithNullability, leastRestrictive, shouldRaggedFixedLengthValueUnionBeVariable
builder, canonize, copyType, createDecimalProduct, createDecimalQuotient, createJavaType, createJoinType, createStructType, createStructType, createStructType, getDefaultCharset, getTypeSystem, isJavaType, leastRestrictiveStructuredType, useDoubleMultiplication
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
builder, copyType, createArrayType, createDecimalProduct, createDecimalQuotient, createJavaType, createJoinType, createMapType, createMultisetType, createSqlIntervalType, createSqlType, createSqlType, createSqlType, createStructType, createStructType, createStructType, createTypeWithCharsetAndCollation, createTypeWithNullability, getDefaultCharset, getTypeSystem, leastRestrictive, useDoubleMultiplication
public FlinkTypeFactory(org.apache.calcite.rel.type.RelDataTypeSystem typeSystem)
public static TypeInformation<?> toTypeInfo(org.apache.calcite.rel.type.RelDataType relDataType)
public org.apache.calcite.rel.type.RelDataType createTypeFromTypeInfo(TypeInformation<?> typeInfo)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.