org.apache.drill.exec.planner.common

Class DrillJoinRelBase

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

All Implemented Interfaces:

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

Direct Known Subclasses:

DrillJoinRel, DrillSemiJoinRel, JoinPrel, PluginJoinRel

public abstract class DrillJoinRelBase
extends org.apache.calcite.rel.core.Join
implements DrillJoin

Base class for logical and physical Joins implemented in Drill.

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
protected List<Boolean>	filterNulls The join key positions for which null values will not match.
protected List<Integer>	leftKeys
protected List<Integer>	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

Constructor Summary

Constructors

Constructor and Description
DrillJoinRelBase(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)

Method Summary

Modifier and Type	Method and Description
protected org.apache.calcite.plan.RelOptCost	computeCartesianJoinCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
protected org.apache.calcite.plan.RelOptCost	computeHashJoinCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
static org.apache.calcite.plan.RelOptCost	computeHashJoinCostWithRowCntKeySize(org.apache.calcite.plan.RelOptPlanner planner, double probeRowCount, double buildRowCount, int keySize)
protected org.apache.calcite.plan.RelOptCost	computeLogicalJoinCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
org.apache.calcite.plan.RelOptCost	computeSelfCost(org.apache.calcite.plan.RelOptPlanner planner, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
double	estimateRowCount(org.apache.calcite.rel.metadata.RelMetadataQuery mq)
List<Integer>	getLeftKeys()
List<Integer>	getRightKeys()
static <T> boolean	isUnique(List<T> list)
static boolean	uniqueFieldNames(org.apache.calcite.rel.type.RelDataType rowType)

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

accept, analyzeCondition, copy, copy, createJoinType, deriveJoinRowType, deriveRowType, estimateJoinedRows, explainTerms, getChildExps, getCondition, getJoinType, getSystemFieldList, getVariablesSet, isSemiJoin, isSemiJoinDone, 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, 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.drill.exec.planner.logical.DrillJoin

getCondition, getJoinType, getLeft, getRight, isSemiJoin

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

leftKeys

protected List<Integer> leftKeys

rightKeys

protected List<Integer> rightKeys

filterNulls

protected List<Boolean> filterNulls

The join key positions for which null values will not match.

Constructor Detail

DrillJoinRelBase

public DrillJoinRelBase(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)

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.Join

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.core.Join

uniqueFieldNames

public static boolean uniqueFieldNames(org.apache.calcite.rel.type.RelDataType rowType)

isUnique

public static <T> boolean isUnique(List<T> list)

getLeftKeys

public List<Integer> getLeftKeys()

Specified by:

getLeftKeys in interface DrillJoin

getRightKeys

public List<Integer> getRightKeys()

Specified by:

getRightKeys in interface DrillJoin

computeCartesianJoinCost

protected org.apache.calcite.plan.RelOptCost computeCartesianJoinCost(org.apache.calcite.plan.RelOptPlanner planner,
                                                                      org.apache.calcite.rel.metadata.RelMetadataQuery mq)

computeLogicalJoinCost

protected org.apache.calcite.plan.RelOptCost computeLogicalJoinCost(org.apache.calcite.plan.RelOptPlanner planner,
                                                                    org.apache.calcite.rel.metadata.RelMetadataQuery mq)

computeHashJoinCost

protected org.apache.calcite.plan.RelOptCost computeHashJoinCost(org.apache.calcite.plan.RelOptPlanner planner,
                                                                 org.apache.calcite.rel.metadata.RelMetadataQuery mq)

computeHashJoinCostWithRowCntKeySize

public static org.apache.calcite.plan.RelOptCost computeHashJoinCostWithRowCntKeySize(org.apache.calcite.plan.RelOptPlanner planner,
                                                                                      double probeRowCount,
                                                                                      double buildRowCount,
                                                                                      int keySize)