public abstract static class AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase extends Object
DataSetPythonCorrelate
or DataStreamPythonCorrelate
.Modifier and Type | Field and Description |
---|---|
protected org.apache.calcite.rel.RelNode |
convInput |
protected org.apache.calcite.rel.RelNode |
correlateRel |
protected org.apache.flink.table.plan.nodes.logical.FlinkLogicalCorrelate |
join |
protected org.apache.calcite.rel.RelNode |
right |
protected org.apache.calcite.plan.RelTraitSet |
traitSet |
Constructor and Description |
---|
PythonCorrelateFactoryBase(org.apache.calcite.rel.RelNode rel,
org.apache.calcite.plan.Convention physicalConvention) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.RelNode |
convertToCorrelate() |
abstract org.apache.calcite.rel.RelNode |
createPythonCorrelateNode(org.apache.calcite.rel.RelNode relNode,
scala.Option<org.apache.calcite.rex.RexNode> condition) |
protected final org.apache.calcite.rel.RelNode correlateRel
protected final org.apache.flink.table.plan.nodes.logical.FlinkLogicalCorrelate join
protected final org.apache.calcite.plan.RelTraitSet traitSet
protected final org.apache.calcite.rel.RelNode convInput
protected final org.apache.calcite.rel.RelNode right
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.