public interface DataStreamRel extends org.apache.calcite.rel.RelNode, FlinkRel
Modifier and Type | Method and Description |
---|---|
DataStream<Object> |
translateToPlan(StreamTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType)
Translates the FlinkRelNode into a Flink 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
DataStream<Object> translateToPlan(StreamTableEnvironment tableEnv, scala.Option<TypeInformation<Object>> expectedType)
tableEnv
- The StreamTableEnvironment
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.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.