public interface FlinkRel
Modifier and Type | Method and Description |
---|---|
double |
estimateDataTypeSize(org.apache.calcite.rel.type.RelDataType t) |
double |
estimateRowSize(org.apache.calcite.rel.type.RelDataType rowType) |
MapFunction<Object,Object> |
getConversionMapper(TableConfig config,
boolean nullableInput,
TypeInformation<Object> inputType,
TypeInformation<Object> expectedType,
String conversionOperatorName,
scala.collection.Seq<String> fieldNames,
scala.Option<int[]> inputPojoFieldMapping) |
String |
getExpressionString(org.apache.calcite.rex.RexNode expr,
scala.collection.immutable.List<String> inFields,
scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>> localExprsTable) |
String getExpressionString(org.apache.calcite.rex.RexNode expr, scala.collection.immutable.List<String> inFields, scala.Option<scala.collection.immutable.List<org.apache.calcite.rex.RexNode>> localExprsTable)
MapFunction<Object,Object> getConversionMapper(TableConfig config, boolean nullableInput, TypeInformation<Object> inputType, TypeInformation<Object> expectedType, String conversionOperatorName, scala.collection.Seq<String> fieldNames, scala.Option<int[]> inputPojoFieldMapping)
double estimateRowSize(org.apache.calcite.rel.type.RelDataType rowType)
double estimateDataTypeSize(org.apache.calcite.rel.type.RelDataType t)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.