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 |
buildRowDataType(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Creates a struct type with the input fieldNames and input fieldTypes using FlinkTypeFactory
|
org.apache.calcite.rel.type.RelDataType |
createArrayType(org.apache.calcite.rel.type.RelDataType elementType,
long maxCardinality) |
org.apache.calcite.rel.type.RelDataType |
createSqlType(org.apache.calcite.sql.type.SqlTypeName typeName,
int precision) |
org.apache.calcite.rel.type.RelDataType |
createTypeFromTypeInfo(TypeInformation<?> typeInfo) |
org.apache.calcite.rel.type.RelDataType |
createTypeWithNullability(org.apache.calcite.rel.type.RelDataType relDataType,
boolean nullable) |
static TypeInformation<?> |
toTypeInfo(org.apache.calcite.rel.type.RelDataType relDataType) |
createStructType, createSyntheticType, createType, getJavaClass, toSql
canonize, createMapType, createMultisetType, createSqlIntervalType, createSqlType, createSqlType, createTypeWithCharsetAndCollation, leastRestrictive, 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, 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)
public org.apache.calcite.rel.type.RelDataType buildRowDataType(String[] fieldNames, TypeInformation<?>[] fieldTypes)
fieldNames
- field namesfieldTypes
- field types, every element is Flink's TypeInformation
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 nullable)
createTypeWithNullability
in interface org.apache.calcite.rel.type.RelDataTypeFactory
createTypeWithNullability
in class org.apache.calcite.sql.type.SqlTypeFactoryImpl
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.