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

Class HiveAlgorithmsUtil

java.lang.Object

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

public class HiveAlgorithmsUtil
extends Object

Method Summary

Methods

Modifier and Type	Method and Description
double	computeBucketMapJoinCPUCost(com.google.common.collect.ImmutableList<Double> cardinalities, org.apache.calcite.util.ImmutableBitSet streaming)
double	computeBucketMapJoinIOCost(com.google.common.collect.ImmutableList<org.apache.calcite.util.Pair<Double,Double>> relationInfos, org.apache.calcite.util.ImmutableBitSet streaming, int parallelism)
static org.apache.calcite.plan.RelOptCost	computeCardinalityBasedCost(HiveRelNode hr)
static double	computeMapJoinCPUCost(com.google.common.collect.ImmutableList<Double> cardinalities, org.apache.calcite.util.ImmutableBitSet streaming)
double	computeMapJoinIOCost(com.google.common.collect.ImmutableList<org.apache.calcite.util.Pair<Double,Double>> relationInfos, org.apache.calcite.util.ImmutableBitSet streaming, int parallelism)
HiveCost	computeScanCost(double cardinality, double avgTupleSize)
static double	computeSMBMapJoinCPUCost(com.google.common.collect.ImmutableList<Double> cardinalities)
double	computeSMBMapJoinIOCost(com.google.common.collect.ImmutableList<org.apache.calcite.util.Pair<Double,Double>> relationInfos, org.apache.calcite.util.ImmutableBitSet streaming, int parallelism)
double	computeSortCPUCost(Double cardinality)
double	computeSortIOCost(org.apache.calcite.util.Pair<Double,Double> relationInfo)
double	computeSortMergeCPUCost(com.google.common.collect.ImmutableList<Double> cardinalities, org.apache.calcite.util.ImmutableBitSet sorted)
double	computeSortMergeIOCost(com.google.common.collect.ImmutableList<org.apache.calcite.util.Pair<Double,Double>> relationInfos)
static com.google.common.collect.ImmutableList<org.apache.calcite.rel.RelCollation>	getJoinCollation(HiveCalciteUtil.JoinPredicateInfo joinPredInfo, HiveJoin.MapJoinStreamingRelation streamingRelation)
static org.apache.calcite.rel.RelDistribution	getJoinDistribution(HiveCalciteUtil.JoinPredicateInfo joinPredInfo, HiveJoin.MapJoinStreamingRelation streamingRelation)
static Double	getJoinMemory(HiveJoin join)
static Double	getJoinMemory(HiveJoin join, HiveJoin.MapJoinStreamingRelation streamingSide)
static org.apache.calcite.rel.RelDistribution	getJoinRedistribution(HiveCalciteUtil.JoinPredicateInfo joinPredInfo)
static Integer	getSplitCountWithoutRepartition(HiveJoin join)
static Integer	getSplitCountWithRepartition(HiveJoin join)
static boolean	isFittingIntoMemory(Double maxSize, org.apache.calcite.rel.RelNode input, int buckets)

Methods inherited from class java.lang.Object

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

Method Detail

computeCardinalityBasedCost

public static org.apache.calcite.plan.RelOptCost computeCardinalityBasedCost(HiveRelNode hr)

computeScanCost

public HiveCost computeScanCost(double cardinality,
                       double avgTupleSize)

computeSortMergeCPUCost

public double computeSortMergeCPUCost(com.google.common.collect.ImmutableList<Double> cardinalities,
                             org.apache.calcite.util.ImmutableBitSet sorted)

computeSortCPUCost

public double computeSortCPUCost(Double cardinality)

computeSortMergeIOCost

public double computeSortMergeIOCost(com.google.common.collect.ImmutableList<org.apache.calcite.util.Pair<Double,Double>> relationInfos)

computeSortIOCost

public double computeSortIOCost(org.apache.calcite.util.Pair<Double,Double> relationInfo)

computeMapJoinCPUCost

public static double computeMapJoinCPUCost(com.google.common.collect.ImmutableList<Double> cardinalities,
                           org.apache.calcite.util.ImmutableBitSet streaming)

computeMapJoinIOCost

public double computeMapJoinIOCost(com.google.common.collect.ImmutableList<org.apache.calcite.util.Pair<Double,Double>> relationInfos,
                          org.apache.calcite.util.ImmutableBitSet streaming,
                          int parallelism)

computeBucketMapJoinCPUCost

public double computeBucketMapJoinCPUCost(com.google.common.collect.ImmutableList<Double> cardinalities,
                                 org.apache.calcite.util.ImmutableBitSet streaming)

computeBucketMapJoinIOCost

public double computeBucketMapJoinIOCost(com.google.common.collect.ImmutableList<org.apache.calcite.util.Pair<Double,Double>> relationInfos,
                                org.apache.calcite.util.ImmutableBitSet streaming,
                                int parallelism)

computeSMBMapJoinCPUCost

public static double computeSMBMapJoinCPUCost(com.google.common.collect.ImmutableList<Double> cardinalities)

computeSMBMapJoinIOCost

public double computeSMBMapJoinIOCost(com.google.common.collect.ImmutableList<org.apache.calcite.util.Pair<Double,Double>> relationInfos,
                             org.apache.calcite.util.ImmutableBitSet streaming,
                             int parallelism)

isFittingIntoMemory

public static boolean isFittingIntoMemory(Double maxSize,
                          org.apache.calcite.rel.RelNode input,
                          int buckets)

getJoinCollation

public static com.google.common.collect.ImmutableList<org.apache.calcite.rel.RelCollation> getJoinCollation(HiveCalciteUtil.JoinPredicateInfo joinPredInfo,
                                                                                            HiveJoin.MapJoinStreamingRelation streamingRelation)

getJoinRedistribution

public static org.apache.calcite.rel.RelDistribution getJoinRedistribution(HiveCalciteUtil.JoinPredicateInfo joinPredInfo)

getJoinDistribution

public static org.apache.calcite.rel.RelDistribution getJoinDistribution(HiveCalciteUtil.JoinPredicateInfo joinPredInfo,
                                                         HiveJoin.MapJoinStreamingRelation streamingRelation)

getJoinMemory

public static Double getJoinMemory(HiveJoin join)

getJoinMemory

public static Double getJoinMemory(HiveJoin join,
                   HiveJoin.MapJoinStreamingRelation streamingSide)

getSplitCountWithRepartition

public static Integer getSplitCountWithRepartition(HiveJoin join)

getSplitCountWithoutRepartition

public static Integer getSplitCountWithoutRepartition(HiveJoin join)