org.apache.drill.exec.physical.impl.join

Class HashJoinMemoryCalculatorImpl

java.lang.Object

org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl

All Implemented Interfaces:

HashJoinMemoryCalculator, HashJoinStateCalculator<HashJoinMemoryCalculator.BuildSidePartitioning>

public class HashJoinMemoryCalculatorImpl
extends Object
implements HashJoinMemoryCalculator

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl At this point we need to reserve memory for the following: An incoming batch An incomplete batch for each partition If there is available memory we keep the batches for each partition in memory.
static class	HashJoinMemoryCalculatorImpl.NoopBuildSidePartitioningImpl
static class	HashJoinMemoryCalculatorImpl.NoopPostBuildCalculationsImpl
static class	HashJoinMemoryCalculatorImpl.PostBuildCalculationsImpl In this state, we need to make sure there is enough room to spill probe side batches, if spilling is necessary.

Nested classes/interfaces inherited from interface org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculator

HashJoinMemoryCalculator.BatchStat, HashJoinMemoryCalculator.BuildSidePartitioning, HashJoinMemoryCalculator.PartitionStat, HashJoinMemoryCalculator.PartitionStatSet, HashJoinMemoryCalculator.PostBuildCalculations

Constructor Summary

Constructors

Constructor and Description
HashJoinMemoryCalculatorImpl(double safetyFactor, double fragmentationFactor, double hashTableDoublingFactor, String hashTableCalculatorType, boolean semiJoin)

Method Summary

Modifier and Type	Method and Description
HashJoinState	getState() The current HashJoinState corresponding to this calculator.
void	initialize(boolean doMemoryCalculation)
HashJoinMemoryCalculator.BuildSidePartitioning	next() Signifies that the current state is complete and returns the next HashJoinStateCalculator.

Methods inherited from class java.lang.Object

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

Constructor Detail

HashJoinMemoryCalculatorImpl

public HashJoinMemoryCalculatorImpl(double safetyFactor,
                                    double fragmentationFactor,
                                    double hashTableDoublingFactor,
                                    String hashTableCalculatorType,
                                    boolean semiJoin)

Method Detail

initialize

public void initialize(boolean doMemoryCalculation)

Specified by:

initialize in interface HashJoinMemoryCalculator

next

public HashJoinMemoryCalculator.BuildSidePartitioning next()

Description copied from interface: HashJoinStateCalculator

Signifies that the current state is complete and returns the next HashJoinStateCalculator. Returns null in the case where there is no next state.

Specified by:

next in interface HashJoinStateCalculator<HashJoinMemoryCalculator.BuildSidePartitioning>

Returns:

The next HashJoinStateCalculator or null if this was the last state.

getState

public HashJoinState getState()

Description copied from interface: HashJoinStateCalculator

The current HashJoinState corresponding to this calculator.

Specified by:

getState in interface HashJoinStateCalculator<HashJoinMemoryCalculator.BuildSidePartitioning>

Returns: