org.apache.drill.exec.planner.logical

Class RowKeyJoinRel

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.calcite.rel.BiRel

org.apache.calcite.rel.core.Join

org.apache.drill.exec.planner.common.DrillJoinRelBase

org.apache.drill.exec.planner.logical.DrillJoinRel

org.apache.drill.exec.planner.logical.RowKeyJoinRel

All Implemented Interfaces:

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

public class RowKeyJoinRel
extends DrillJoinRel
implements DrillRel

Nested Class Summary

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

org.apache.calcite.rel.RelNode.Context

Field Summary

Fields inherited from class org.apache.drill.exec.planner.logical.DrillJoinRel

EQUALITY_CONDITION

Fields inherited from class org.apache.drill.exec.planner.common.DrillJoinRelBase

filterNulls, leftKeys, rightKeys

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

condition, joinInfo, joinType, variablesSet

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

left, right

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

digest, id, rowType, traitSet

Fields inherited from interface org.apache.drill.exec.planner.logical.DrillRel

DRILL_LOGICAL

Constructor Summary

Constructors

Constructor and Description
RowKeyJoinRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, org.apache.calcite.rex.RexNode condition, org.apache.calcite.rel.core.JoinRelType joinType)
RowKeyJoinRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, org.apache.calcite.rex.RexNode condition, org.apache.calcite.rel.core.JoinRelType joinType, boolean isSemiJoin)
RowKeyJoinRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, org.apache.calcite.rex.RexNode condition, org.apache.calcite.rel.core.JoinRelType joinType, int joinControl)
RowKeyJoinRel(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traits, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, org.apache.calcite.rex.RexNode condition, org.apache.calcite.rel.core.JoinRelType joinType, List<Integer> leftKeys, List<Integer> rightKeys)

Method Summary

Modifier and Type	Method and Description
static RowKeyJoinRel	convert(Join join, ConversionContext context)
RowKeyJoinRel	copy(org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rex.RexNode condition, org.apache.calcite.rel.RelNode left, org.apache.calcite.rel.RelNode right, org.apache.calcite.rel.core.JoinRelType joinType, boolean semiJoinDone)
org.apache.calcite.rel.type.RelDataType	deriveRowType()
LogicalOperator	implement(DrillImplementor implementor)
boolean	isSemiJoin() Returns whether this RowKeyJoin represents a org.apache.calcite.rel.core.SemiJoin
boolean	isValid(org.apache.calcite.util.Litmus litmus, org.apache.calcite.rel.RelNode.Context context) The parent method relies the class being an instance of org.apache.calcite.rel.core.SemiJoin in deciding row-type validity.

Methods inherited from class org.apache.drill.exec.planner.logical.DrillJoinRel

getJoinCondition, getJoinInputs, implementInput

Methods inherited from class org.apache.drill.exec.planner.common.DrillJoinRelBase

computeCartesianJoinCost, computeHashJoinCost, computeHashJoinCostWithRowCntKeySize, computeLogicalJoinCost, computeSelfCost, estimateRowCount, getLeftKeys, getRightKeys, isUnique, uniqueFieldNames

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

accept, analyzeCondition, copy, createJoinType, deriveJoinRowType, estimateJoinedRows, explainTerms, getChildExps, getCondition, getJoinType, getSystemFieldList, getVariablesSet, isSemiJoinDone

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

childrenAccept, getInputs, getLeft, getRight, replaceInput

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

accept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, equals, explain, getCluster, getCollationList, getConvention, getCorrelVariable, 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, computeSelfCost, copy, estimateRowCount, explain, getChildExps, getCollationList, getConvention, getCorrelVariable, getExpectedInputRowType, getInput, getInputs, getQuery, getRelTypeName, getRows, getRowType, getTable, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, metadata, onRegister, recomputeDigest, register, replaceInput

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

getCluster, getDescription, getDigest, getId, getTraitSet

Methods inherited from interface org.apache.drill.exec.planner.logical.DrillJoin

getCondition, getJoinType, getLeft, getRight

Constructor Detail

RowKeyJoinRel

public RowKeyJoinRel(org.apache.calcite.plan.RelOptCluster cluster,
                     org.apache.calcite.plan.RelTraitSet traits,
                     org.apache.calcite.rel.RelNode left,
                     org.apache.calcite.rel.RelNode right,
                     org.apache.calcite.rex.RexNode condition,
                     org.apache.calcite.rel.core.JoinRelType joinType)

RowKeyJoinRel

public RowKeyJoinRel(org.apache.calcite.plan.RelOptCluster cluster,
                     org.apache.calcite.plan.RelTraitSet traits,
                     org.apache.calcite.rel.RelNode left,
                     org.apache.calcite.rel.RelNode right,
                     org.apache.calcite.rex.RexNode condition,
                     org.apache.calcite.rel.core.JoinRelType joinType,
                     boolean isSemiJoin)

RowKeyJoinRel

public RowKeyJoinRel(org.apache.calcite.plan.RelOptCluster cluster,
                     org.apache.calcite.plan.RelTraitSet traits,
                     org.apache.calcite.rel.RelNode left,
                     org.apache.calcite.rel.RelNode right,
                     org.apache.calcite.rex.RexNode condition,
                     org.apache.calcite.rel.core.JoinRelType joinType,
                     int joinControl)

RowKeyJoinRel

public RowKeyJoinRel(org.apache.calcite.plan.RelOptCluster cluster,
                     org.apache.calcite.plan.RelTraitSet traits,
                     org.apache.calcite.rel.RelNode left,
                     org.apache.calcite.rel.RelNode right,
                     org.apache.calcite.rex.RexNode condition,
                     org.apache.calcite.rel.core.JoinRelType joinType,
                     List<Integer> leftKeys,
                     List<Integer> rightKeys)
              throws org.apache.calcite.rel.InvalidRelException

Throws:

org.apache.calcite.rel.InvalidRelException

Method Detail

copy

public RowKeyJoinRel copy(org.apache.calcite.plan.RelTraitSet traitSet,
                          org.apache.calcite.rex.RexNode condition,
                          org.apache.calcite.rel.RelNode left,
                          org.apache.calcite.rel.RelNode right,
                          org.apache.calcite.rel.core.JoinRelType joinType,
                          boolean semiJoinDone)

Overrides:

copy in class DrillJoinRel

implement

public LogicalOperator implement(DrillImplementor implementor)

Specified by:

implement in interface DrillRel

Overrides:

implement in class DrillJoinRel

isSemiJoin

public boolean isSemiJoin()

Returns whether this RowKeyJoin represents a org.apache.calcite.rel.core.SemiJoin

Specified by:

isSemiJoin in interface DrillJoin

Overrides:

isSemiJoin in class org.apache.calcite.rel.core.Join

Returns:

true if join represents a org.apache.calcite.rel.core.SemiJoin, false otherwise.

deriveRowType

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

Overrides:

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

convert

public static RowKeyJoinRel convert(Join join,
                                    ConversionContext context)
                             throws org.apache.calcite.rel.InvalidRelException

Throws:

org.apache.calcite.rel.InvalidRelException

isValid

public boolean isValid(org.apache.calcite.util.Litmus litmus,
                       org.apache.calcite.rel.RelNode.Context context)

The parent method relies the class being an instance of org.apache.calcite.rel.core.SemiJoin in deciding row-type validity. We override this method to account for the RowKeyJoinRel logical rel representing both regular and semi-joins

Specified by:

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

Overrides:

isValid in class org.apache.calcite.rel.core.Join