Package org.apache.calcite.rel.core

Class ConditionalCorrelate

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.calcite.rel.BiRel

org.apache.calcite.rel.core.Correlate

org.apache.calcite.rel.core.ConditionalCorrelate

All Implemented Interfaces:

Cloneable, RelOptNode, Hintable, RelNode

Direct Known Subclasses:

EnumerableConditionalCorrelate, LogicalConditionalCorrelate

public abstract class ConditionalCorrelate
extends Correlate

This is a extension of Correlate that contains a condition. When removing SOME/IN subqueries, the condition need to be retained in the left mark type Correlate (it cannot be pulled up or pushed down). This is why ConditionalCorrelate extends the condition.

See Also:

• CoreRules.FILTER_SUB_QUERY_TO_MARK_CORRELATE
• CoreRules.PROJECT_SUB_QUERY_TO_MARK_CORRELATE

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.rel.RelNode

RelNode.Context

Field Summary

Fields

Modifier and Type	Field	Description
protected final RexNode	condition

Fields inherited from class org.apache.calcite.rel.core.Correlate

correlationId, hints, joinType, requiredColumns

Fields inherited from class org.apache.calcite.rel.BiRel

left, right

Fields inherited from class org.apache.calcite.rel.AbstractRelNode

digest, id, rowType, traitSet

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConditionalCorrelate(RelOptCluster cluster, RelTraitSet traitSet, List<RelHint> hints, RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, JoinRelType joinType, RexNode condition)

Method Summary

Modifier and Type	Method	Description
ConditionalCorrelate	copy(RelTraitSet traitSet, List<RelNode> inputs)	Creates a copy of this relational expression, perhaps changing traits and inputs.
abstract ConditionalCorrelate	copy(RelTraitSet traitSet, RelNode left, RelNode right, CorrelationId correlationId, ImmutableBitSet requiredColumns, JoinRelType joinType, RexNode condition)
protected RelDataType	deriveRowType()
RelWriter	explainTerms(RelWriter pw)	Describes the inputs and attributes of this relational expression.
RexNode	getCondition()

Methods inherited from class org.apache.calcite.rel.core.Correlate

computeSelfCost, copy, estimateRowCount, getCorrelationId, getCorrelVariable, getHints, getJoinType, getRequiredColumns, getVariablesSet, isValid

Methods inherited from class org.apache.calcite.rel.BiRel

childrenAccept, getInputs, getLeft, getRight, replaceInput

Methods inherited from class org.apache.calcite.rel.AbstractRelNode

accept, accept, collectVariablesSet, collectVariablesUsed, deepEquals, deepHashCode, equals, explain, getCluster, getConvention, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getRelDigest, getRelTypeName, getRowType, getTable, getTraitSet, hashCode, isEnforcer, metadata, onRegister, recomputeDigest, register, sole, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.calcite.rel.hint.Hintable

attachHints, withHints

Methods inherited from interface org.apache.calcite.rel.RelNode

explain, fieldIsNullable, stripped

Field Details

condition

protected final RexNode condition

Constructor Details

ConditionalCorrelate

protected ConditionalCorrelate(RelOptCluster cluster,
 RelTraitSet traitSet,
 List<RelHint> hints,
 RelNode left,
 RelNode right,
 CorrelationId correlationId,
 ImmutableBitSet requiredColumns,
 JoinRelType joinType,
 RexNode condition)

Method Details

copy

public ConditionalCorrelate copy(RelTraitSet traitSet,
 List<RelNode> inputs)

Description copied from interface: RelNode

Creates a copy of this relational expression, perhaps changing traits and inputs.

Sub-classes with other important attributes are encouraged to create variants of this method with more parameters.

Specified by:

copy in interface RelNode

Overrides:

copy in class Correlate

Parameters:

traitSet - Trait set

inputs - Inputs

Returns:

Copy of this relational expression, substituting traits and inputs

copy

public abstract ConditionalCorrelate copy(RelTraitSet traitSet,
 RelNode left,
 RelNode right,
 CorrelationId correlationId,
 ImmutableBitSet requiredColumns,
 JoinRelType joinType,
 RexNode condition)

explainTerms

public RelWriter explainTerms(RelWriter pw)

Description copied from class: AbstractRelNode

Describes the inputs and attributes of this relational expression. Each node should call super.explainTerms, then call the RelWriter.input(String, RelNode) and RelWriter.item(String, Object) methods for each input and attribute.

Overrides:

explainTerms in class Correlate

Parameters:

pw - Plan writer

Returns:

Plan writer for fluent-explain pattern

deriveRowType

protected RelDataType deriveRowType()

Overrides:

deriveRowType in class Correlate

getCondition

public RexNode getCondition()

Overrides:

getCondition in class Correlate