public class DataStreamUnion extends org.apache.calcite.rel.BiRel implements DataStreamRel
Constructor and Description |
---|
DataStreamUnion(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.rel.RelNode left,
org.apache.calcite.rel.RelNode right,
org.apache.calcite.rel.type.RelDataType rowType) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.RelNode |
copy(org.apache.calcite.plan.RelTraitSet traitSet,
List<org.apache.calcite.rel.RelNode> inputs) |
org.apache.calcite.rel.type.RelDataType |
deriveRowType() |
org.apache.calcite.rel.RelWriter |
explainTerms(org.apache.calcite.rel.RelWriter pw) |
String |
toString() |
DataStream<Object> |
translateToPlan(StreamTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType)
Translates the FlinkRelNode into a Flink operator.
|
childrenAccept, getInputs, getLeft, getRight, replaceInput
accept, accept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, computeSelfCost, estimateRowCount, explain, getChildExps, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, sole
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, computeSelfCost, 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
public DataStreamUnion(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, org.apache.calcite.rel.type.RelDataType rowType)
public org.apache.calcite.rel.type.RelDataType deriveRowType()
deriveRowType
in class org.apache.calcite.rel.AbstractRelNode
public org.apache.calcite.rel.RelNode copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
copy
in interface org.apache.calcite.rel.RelNode
copy
in class org.apache.calcite.rel.AbstractRelNode
public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)
explainTerms
in class org.apache.calcite.rel.BiRel
public String toString()
toString
in class org.apache.calcite.rel.AbstractRelNode
public DataStream<Object> translateToPlan(StreamTableEnvironment tableEnv, scala.Option<TypeInformation<Object>> expectedType)
DataStreamRel
translateToPlan
in interface DataStreamRel
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.