org.apache.hadoop.hive.ql.optimizer.calcite.reloperators

Class HiveMultiJoin

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.hadoop.hive.ql.optimizer.calcite.reloperators.HiveMultiJoin

All Implemented Interfaces:

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

public final class HiveMultiJoin
extends org.apache.calcite.rel.AbstractRelNode

A HiveMultiJoin represents a succession of binary joins.

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.calcite.rel.AbstractRelNode

digest, id, traitSet

Constructor Summary

Constructors

Constructor and Description
HiveMultiJoin(org.apache.calcite.plan.RelOptCluster cluster, List<org.apache.calcite.rel.RelNode> inputs, org.apache.calcite.rex.RexNode condition, org.apache.calcite.rel.type.RelDataType rowType, List<org.apache.calcite.util.Pair<Integer,Integer>> joinInputs, List<org.apache.calcite.rel.core.JoinRelType> joinTypes, List<org.apache.calcite.rex.RexNode> filters)
HiveMultiJoin(org.apache.calcite.plan.RelOptCluster cluster, List<org.apache.calcite.rel.RelNode> inputs, org.apache.calcite.rex.RexNode condition, org.apache.calcite.rel.type.RelDataType rowType, List<org.apache.calcite.util.Pair<Integer,Integer>> joinInputs, List<org.apache.calcite.rel.core.JoinRelType> joinTypes, List<org.apache.calcite.rex.RexNode> filters, HiveCalciteUtil.JoinPredicateInfo joinPredicateInfo) Constructs a MultiJoin.

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.rel.RelNode	accept(org.apache.calcite.rex.RexShuttle shuttle)
org.apache.calcite.rel.RelNode	copy(org.apache.calcite.plan.RelTraitSet traitSet, List<org.apache.calcite.rel.RelNode> inputs)
org.apache.calcite.rel.type.RelDataType	deriveRowType()
org.apache.calcite.rel.RelWriter	explainTerms(org.apache.calcite.rel.RelWriter pw)
List<org.apache.calcite.rex.RexNode>	getChildExps()
org.apache.calcite.rex.RexNode	getCondition()
List<org.apache.calcite.rel.RelNode>	getInputs()
List<org.apache.calcite.rex.RexNode>	getJoinFilters()
List<org.apache.calcite.util.Pair<Integer,Integer>>	getJoinInputs()
HiveCalciteUtil.JoinPredicateInfo	getJoinPredicateInfo()
List<org.apache.calcite.rel.core.JoinRelType>	getJoinTypes()
boolean	isOuterJoin()
void	replaceInput(int ordinalInParent, org.apache.calcite.rel.RelNode p)

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

accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeDigest, computeSelfCost, computeSelfCost, estimateRowCount, explain, getCluster, getCollationList, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getQuery, getRelTypeName, getRows, getRowType, getTable, getTraitSet, getVariablesSet, getVariablesStopped, isDistinct, isKey, isValid, isValid, metadata, onRegister, recomputeDigest, register, sole, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

HiveMultiJoin

public HiveMultiJoin(org.apache.calcite.plan.RelOptCluster cluster,
                     List<org.apache.calcite.rel.RelNode> inputs,
                     org.apache.calcite.rex.RexNode condition,
                     org.apache.calcite.rel.type.RelDataType rowType,
                     List<org.apache.calcite.util.Pair<Integer,Integer>> joinInputs,
                     List<org.apache.calcite.rel.core.JoinRelType> joinTypes,
                     List<org.apache.calcite.rex.RexNode> filters,
                     HiveCalciteUtil.JoinPredicateInfo joinPredicateInfo)

Constructs a MultiJoin.

Parameters:

cluster - cluster that join belongs to

inputs - inputs into this multi-join

condition - join filter applicable to this join node

rowType - row type of the join result of this node

joinInputs -

joinTypes - the join type corresponding to each input; if an input is null-generating in a left or right outer join, the entry indicates the type of outer join; otherwise, the entry is set to INNER

filters - filters associated with each join input

joinPredicateInfo - join predicate information

HiveMultiJoin

public HiveMultiJoin(org.apache.calcite.plan.RelOptCluster cluster,
                     List<org.apache.calcite.rel.RelNode> inputs,
                     org.apache.calcite.rex.RexNode condition,
                     org.apache.calcite.rel.type.RelDataType rowType,
                     List<org.apache.calcite.util.Pair<Integer,Integer>> joinInputs,
                     List<org.apache.calcite.rel.core.JoinRelType> joinTypes,
                     List<org.apache.calcite.rex.RexNode> filters)

Method Detail

replaceInput

public void replaceInput(int ordinalInParent,
                         org.apache.calcite.rel.RelNode p)

Specified by:

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

Overrides:

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

copy

public org.apache.calcite.rel.RelNode copy(org.apache.calcite.plan.RelTraitSet traitSet,
                                           List<org.apache.calcite.rel.RelNode> inputs)

Specified by:

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

Overrides:

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

explainTerms

public org.apache.calcite.rel.RelWriter explainTerms(org.apache.calcite.rel.RelWriter pw)

Overrides:

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

deriveRowType

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

Overrides:

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

getInputs

public List<org.apache.calcite.rel.RelNode> getInputs()

Specified by:

getInputs in interface org.apache.calcite.plan.RelOptNode

Specified by:

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

Overrides:

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

getChildExps

public List<org.apache.calcite.rex.RexNode> getChildExps()

Specified by:

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

Overrides:

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

accept

public org.apache.calcite.rel.RelNode accept(org.apache.calcite.rex.RexShuttle shuttle)

Specified by:

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

Overrides:

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

getCondition

public org.apache.calcite.rex.RexNode getCondition()

Returns:

join filters associated with this MultiJoin

isOuterJoin

public boolean isOuterJoin()

Returns:

true if the MultiJoin contains a (partial) outer join.

getJoinInputs

public List<org.apache.calcite.util.Pair<Integer,Integer>> getJoinInputs()

Returns:

join relationships between inputs

getJoinTypes

public List<org.apache.calcite.rel.core.JoinRelType> getJoinTypes()

Returns:

join types of each input

getJoinFilters

public List<org.apache.calcite.rex.RexNode> getJoinFilters()

Returns:

join conditions filters

getJoinPredicateInfo

public HiveCalciteUtil.JoinPredicateInfo getJoinPredicateInfo()

Returns:

the join predicate information