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

Class HiveCalciteUtil.JoinPredicateInfo

java.lang.Object

org.apache.hadoop.hive.ql.optimizer.calcite.HiveCalciteUtil.JoinPredicateInfo

Enclosing class:

HiveCalciteUtil

public static class HiveCalciteUtil.JoinPredicateInfo
extends Object

JoinPredicateInfo represents Join condition; JoinPredicate Info uses JoinLeafPredicateInfo to represent individual conjunctive elements in the predicate.
JoinPredicateInfo = JoinLeafPredicateInfo1 and JoinLeafPredicateInfo2...

JoinPredicateInfo:
1. preserves the order of conjuctive elements for equi-join(equiJoinPredicateElements)
2. Stores set of projection indexes from left and right child which is part of equi join keys; the indexes are both in child and Join node schema.
3. Keeps a map of projection indexes that are part of join keys to list of conjuctive elements(JoinLeafPredicateInfo) that uses them.

Constructor Summary

Constructors

Constructor and Description
JoinPredicateInfo(List<HiveCalciteUtil.JoinLeafPredicateInfo> nonEquiJoinPredicateElements, List<HiveCalciteUtil.JoinLeafPredicateInfo> equiJoinPredicateElements, List<Set<Integer>> projsJoinKeysInChildSchema, List<Set<Integer>> projsJoinKeysInJoinSchema, Map<Integer,com.google.common.collect.ImmutableList<HiveCalciteUtil.JoinLeafPredicateInfo>> mapOfProjIndxInJoinSchemaToLeafPInfo)

Method Summary

Modifier and Type	Method and Description
static HiveCalciteUtil.JoinPredicateInfo	constructJoinPredicateInfo(HiveMultiJoin mj)
static HiveCalciteUtil.JoinPredicateInfo	constructJoinPredicateInfo(HiveMultiJoin mj, org.apache.calcite.rex.RexNode predicate)
static HiveCalciteUtil.JoinPredicateInfo	constructJoinPredicateInfo(org.apache.calcite.rel.core.Join j)
static HiveCalciteUtil.JoinPredicateInfo	constructJoinPredicateInfo(org.apache.calcite.rel.core.Join j, org.apache.calcite.rex.RexNode predicate)
static HiveCalciteUtil.JoinPredicateInfo	constructJoinPredicateInfo(List<org.apache.calcite.rel.RelNode> inputs, List<org.apache.calcite.rel.type.RelDataTypeField> systemFieldList, org.apache.calcite.rex.RexNode predicate)
List<HiveCalciteUtil.JoinLeafPredicateInfo>	getEquiJoinPredicateElements()
Map<Integer,com.google.common.collect.ImmutableList<HiveCalciteUtil.JoinLeafPredicateInfo>>	getMapOfProjIndxToLeafPInfo()
List<HiveCalciteUtil.JoinLeafPredicateInfo>	getNonEquiJoinPredicateElements()
Set<Integer>	getProjsFromLeftPartOfJoinKeysInChildSchema()
Set<Integer>	getProjsFromLeftPartOfJoinKeysInJoinSchema() NOTE: Join Schema = left Schema + (right Schema offset by left.fieldcount).
Set<Integer>	getProjsFromRightPartOfJoinKeysInChildSchema()
Set<Integer>	getProjsFromRightPartOfJoinKeysInJoinSchema()
Set<Integer>	getProjsJoinKeysInChildSchema(int i)
Set<Integer>	getProjsJoinKeysInJoinSchema(int i)

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinPredicateInfo

public JoinPredicateInfo(List<HiveCalciteUtil.JoinLeafPredicateInfo> nonEquiJoinPredicateElements,
                         List<HiveCalciteUtil.JoinLeafPredicateInfo> equiJoinPredicateElements,
                         List<Set<Integer>> projsJoinKeysInChildSchema,
                         List<Set<Integer>> projsJoinKeysInJoinSchema,
                         Map<Integer,com.google.common.collect.ImmutableList<HiveCalciteUtil.JoinLeafPredicateInfo>> mapOfProjIndxInJoinSchemaToLeafPInfo)

Method Detail

getNonEquiJoinPredicateElements

public List<HiveCalciteUtil.JoinLeafPredicateInfo> getNonEquiJoinPredicateElements()

getEquiJoinPredicateElements

public List<HiveCalciteUtil.JoinLeafPredicateInfo> getEquiJoinPredicateElements()

getProjsFromLeftPartOfJoinKeysInChildSchema

public Set<Integer> getProjsFromLeftPartOfJoinKeysInChildSchema()

getProjsFromRightPartOfJoinKeysInChildSchema

public Set<Integer> getProjsFromRightPartOfJoinKeysInChildSchema()

getProjsJoinKeysInChildSchema

public Set<Integer> getProjsJoinKeysInChildSchema(int i)

getProjsFromLeftPartOfJoinKeysInJoinSchema

public Set<Integer> getProjsFromLeftPartOfJoinKeysInJoinSchema()

NOTE: Join Schema = left Schema + (right Schema offset by left.fieldcount). Hence its ok to return projections from left in child schema.

getProjsFromRightPartOfJoinKeysInJoinSchema

public Set<Integer> getProjsFromRightPartOfJoinKeysInJoinSchema()

getProjsJoinKeysInJoinSchema

public Set<Integer> getProjsJoinKeysInJoinSchema(int i)

getMapOfProjIndxToLeafPInfo

public Map<Integer,com.google.common.collect.ImmutableList<HiveCalciteUtil.JoinLeafPredicateInfo>> getMapOfProjIndxToLeafPInfo()

constructJoinPredicateInfo

public static HiveCalciteUtil.JoinPredicateInfo constructJoinPredicateInfo(org.apache.calcite.rel.core.Join j)
                                                                    throws CalciteSemanticException

Throws:

CalciteSemanticException

constructJoinPredicateInfo

public static HiveCalciteUtil.JoinPredicateInfo constructJoinPredicateInfo(HiveMultiJoin mj)
                                                                    throws CalciteSemanticException

Throws:

CalciteSemanticException

constructJoinPredicateInfo

public static HiveCalciteUtil.JoinPredicateInfo constructJoinPredicateInfo(org.apache.calcite.rel.core.Join j,
                                                                           org.apache.calcite.rex.RexNode predicate)
                                                                    throws CalciteSemanticException

Throws:

CalciteSemanticException

constructJoinPredicateInfo

public static HiveCalciteUtil.JoinPredicateInfo constructJoinPredicateInfo(HiveMultiJoin mj,
                                                                           org.apache.calcite.rex.RexNode predicate)
                                                                    throws CalciteSemanticException

Throws:

CalciteSemanticException

constructJoinPredicateInfo

public static HiveCalciteUtil.JoinPredicateInfo constructJoinPredicateInfo(List<org.apache.calcite.rel.RelNode> inputs,
                                                                           List<org.apache.calcite.rel.type.RelDataTypeField> systemFieldList,
                                                                           org.apache.calcite.rex.RexNode predicate)
                                                                    throws CalciteSemanticException

Throws:

CalciteSemanticException