public interface DataSetRel extends org.apache.calcite.rel.RelNode, FlinkRel
Modifier and Type | Method and Description |
---|---|
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) |
DataSet<Object> |
translateToPlan(BatchTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType)
Translates the
DataSetRel node into a DataSet operator. |
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, copy, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput
getCluster, getDescription, getDigest, getId, getTraitSet
getExpressionString
DataSet<Object> translateToPlan(BatchTableEnvironment tableEnv, scala.Option<TypeInformation<Object>> expectedType)
DataSetRel
node into a DataSet
operator.
tableEnv
- BatchTableEnvironment
of the translated Table.expectedType
- specifies the type the Flink operator should return. The type must
have the same arity as the result. For instance, if the
expected type is a RowTypeInfo this method will return a DataSet of
type Row. If the expected type is Tuple2, the operator will return
a Tuple2 if possible. Row otherwise.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)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.