public class DataStreamCorrelate extends org.apache.calcite.rel.SingleRel implements CommonCorrelate, DataStreamRel
Constructor and Description |
---|
DataStreamCorrelate(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
RowSchema inputSchema,
org.apache.calcite.rel.RelNode input,
FlinkLogicalTableFunctionScan scan,
scala.Option<org.apache.calcite.rex.RexNode> condition,
RowSchema schema,
RowSchema joinSchema,
org.apache.calcite.sql.SemiJoinType joinType,
String ruleDescription) |
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<CRow> |
translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig)
Translates the FlinkRelNode into a Flink operator.
|
childrenAccept, estimateRowCount, getInput, getInputs, replaceInput
accept, accept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, computeSelfCost, 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
correlateOpName, correlateToString, generateCollector, generateFunction, selectToString
consumesRetractions, needsUpdatesAsRetraction, producesUpdates
estimateDataTypeSize, estimateRowSize, getExpressionString
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
public DataStreamCorrelate(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, RowSchema inputSchema, org.apache.calcite.rel.RelNode input, FlinkLogicalTableFunctionScan scan, scala.Option<org.apache.calcite.rex.RexNode> condition, RowSchema schema, RowSchema joinSchema, org.apache.calcite.sql.SemiJoinType joinType, String ruleDescription)
public org.apache.calcite.rel.type.RelDataType deriveRowType()
deriveRowType
in class org.apache.calcite.rel.SingleRel
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 String toString()
toString
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.SingleRel
public DataStream<CRow> translateToPlan(StreamTableEnvironment tableEnv, StreamQueryConfig queryConfig)
DataStreamRel
translateToPlan
in interface DataStreamRel
tableEnv
- The StreamTableEnvironment
of the translated Table.queryConfig
- The configuration for the query to generate.CRow
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.