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

Class HiveOnTezCostModel.TezBucketJoinAlgorithm

java.lang.Object

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

All Implemented Interfaces:

HiveCostModel.JoinAlgorithm

Enclosing class:

HiveOnTezCostModel

public static class HiveOnTezCostModel.TezBucketJoinAlgorithm
extends Object
implements HiveCostModel.JoinAlgorithm

BUCKET_JOIN is a hash joins where one bucket of the non streaming tables is kept in memory at the time.

Field Summary

Fields

Modifier and Type	Field and Description
static HiveCostModel.JoinAlgorithm	INSTANCE

Constructor Summary

Constructors

Constructor and Description
TezBucketJoinAlgorithm()

Method Summary

Modifier and Type	Method and Description
com.google.common.collect.ImmutableList<org.apache.calcite.rel.RelCollation>	getCollation(HiveJoin join)
org.apache.calcite.plan.RelOptCost	getCost(HiveJoin join)
Double	getCumulativeMemoryWithinPhaseSplit(HiveJoin join)
org.apache.calcite.rel.RelDistribution	getDistribution(HiveJoin join)
Double	getMemory(HiveJoin join)
Integer	getSplitCount(HiveJoin join)
boolean	isExecutable(HiveJoin join)
Boolean	isPhaseTransition(HiveJoin join)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final HiveCostModel.JoinAlgorithm INSTANCE

Constructor Detail

TezBucketJoinAlgorithm

public TezBucketJoinAlgorithm()

Method Detail

toString

public String toString()

Specified by:

toString in interface HiveCostModel.JoinAlgorithm

Overrides:

toString in class Object

isExecutable

public boolean isExecutable(HiveJoin join)

Specified by:

isExecutable in interface HiveCostModel.JoinAlgorithm

getCost

public org.apache.calcite.plan.RelOptCost getCost(HiveJoin join)

Specified by:

getCost in interface HiveCostModel.JoinAlgorithm

getCollation

public com.google.common.collect.ImmutableList<org.apache.calcite.rel.RelCollation> getCollation(HiveJoin join)

Specified by:

getCollation in interface HiveCostModel.JoinAlgorithm

getDistribution

public org.apache.calcite.rel.RelDistribution getDistribution(HiveJoin join)

Specified by:

getDistribution in interface HiveCostModel.JoinAlgorithm

getMemory

public Double getMemory(HiveJoin join)

Specified by:

getMemory in interface HiveCostModel.JoinAlgorithm

getCumulativeMemoryWithinPhaseSplit

public Double getCumulativeMemoryWithinPhaseSplit(HiveJoin join)

Specified by:

getCumulativeMemoryWithinPhaseSplit in interface HiveCostModel.JoinAlgorithm

isPhaseTransition

public Boolean isPhaseTransition(HiveJoin join)

Specified by:

isPhaseTransition in interface HiveCostModel.JoinAlgorithm

getSplitCount

public Integer getSplitCount(HiveJoin join)

Specified by:

getSplitCount in interface HiveCostModel.JoinAlgorithm