org.apache.drill.exec.planner.common

Class DrillLateralJoinRelBase

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.calcite.rel.BiRel

org.apache.calcite.rel.core.Correlate

org.apache.drill.exec.planner.common.DrillLateralJoinRelBase

All Implemented Interfaces:

Cloneable, org.apache.calcite.plan.RelOptNode, org.apache.calcite.rel.RelNode, DrillRelNode

Direct Known Subclasses:

DrillLateralJoinRel, LateralJoinPrel

public abstract class DrillLateralJoinRelBase
extends org.apache.calcite.rel.core.Correlate
implements DrillRelNode

Nested Class Summary

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

org.apache.calcite.rel.RelNode.Context

Field Summary

Fields

Modifier and Type	Field and Description
boolean	excludeCorrelateColumn
static String	IMPLICIT_COLUMN

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

correlationId, 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

Constructor and Description
DrillLateralJoinRelBase(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, boolean excludeCorrelateCol, org.apache.calcite.rel.core.CorrelationId correlationId, org.apache.calcite.util.ImmutableBitSet requiredColumns, org.apache.calcite.rel.core.JoinRelType semiJoinType)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.plan.RelOptCost	computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
org.apache.calcite.rel.type.RelDataType	constructRowType(org.apache.calcite.rel.type.RelDataType inputRowType)
protected org.apache.calcite.rel.type.RelDataType	deriveRowType()
double	estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery mq)
int	getInputSize(int ordinal) Returns number of fields in RelDataType for input rel node with specified ordinal considering value of excludeCorrelateColumn.
org.apache.calcite.rel.type.RelDataType	removeImplicitField(org.apache.calcite.rel.type.RelDataType inputRowType)

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

copy, copy, explainTerms, getCorrelationId, getCorrelVariable, 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, computeDigest, computeSelfCost, equals, explain, getChildExps, getCluster, getCollationList, getConvention, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesStopped, hashCode, isDistinct, isKey, isValid, 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.RelNode

accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, copy, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, replaceInput

Methods inherited from interface org.apache.calcite.plan.RelOptNode

getCluster, getDescription, getDigest, getId, getTraitSet

Field Detail

IMPLICIT_COLUMN

public static final String IMPLICIT_COLUMN

See Also:

Constant Field Values

excludeCorrelateColumn

public final boolean excludeCorrelateColumn

Constructor Detail

DrillLateralJoinRelBase

public DrillLateralJoinRelBase(org.apache.calcite.plan.RelOptCluster cluster,
                               org.apache.calcite.plan.RelTraitSet traits,
                               org.apache.calcite.rel.RelNode left,
                               org.apache.calcite.rel.RelNode right,
                               boolean excludeCorrelateCol,
                               org.apache.calcite.rel.core.CorrelationId correlationId,
                               org.apache.calcite.util.ImmutableBitSet requiredColumns,
                               org.apache.calcite.rel.core.JoinRelType semiJoinType)

Method Detail

computeSelfCost

public org.apache.calcite.plan.RelOptCost computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner,
                                                          org.apache.calcite.rel.metadata.RelMetadataQuery mq)

Specified by:

computeSelfCost in interface org.apache.calcite.rel.RelNode

Overrides:

computeSelfCost in class org.apache.calcite.rel.core.Correlate

deriveRowType

protected org.apache.calcite.rel.type.RelDataType deriveRowType()

Overrides:

deriveRowType in class org.apache.calcite.rel.core.Correlate

getInputSize

public int getInputSize(int ordinal)

Returns number of fields in RelDataType for input rel node with specified ordinal considering value of excludeCorrelateColumn.

Parameters:

ordinal - ordinal of input rel node

Returns:

number of fields in input's RelDataType

constructRowType

public org.apache.calcite.rel.type.RelDataType constructRowType(org.apache.calcite.rel.type.RelDataType inputRowType)

removeImplicitField

public org.apache.calcite.rel.type.RelDataType removeImplicitField(org.apache.calcite.rel.type.RelDataType inputRowType)

estimateRowCount

public double estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery mq)

Specified by:

estimateRowCount in interface org.apache.calcite.rel.RelNode

Overrides:

estimateRowCount in class org.apache.calcite.rel.AbstractRelNode