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

Class HashJoinMechanicalMemoryCalculator

java.lang.Object

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

All Implemented Interfaces:

HashJoinMemoryCalculator, HashJoinStateCalculator<HashJoinMemoryCalculator.BuildSidePartitioning>

public class HashJoinMechanicalMemoryCalculator
extends Object
implements HashJoinMemoryCalculator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HashJoinMechanicalMemoryCalculator.MechanicalBuildSidePartitioning
static class	HashJoinMechanicalMemoryCalculator.MechanicalPostBuildCalculations

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	Description
HashJoinMechanicalMemoryCalculator(int maxNumInMemBatches)

Method Summary

Modifier and Type	Method	Description
HashJoinState	getState()	The current HashJoinState corresponding to this calculator.
void	initialize(boolean doMemoryCalc)
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 Details

HashJoinMechanicalMemoryCalculator

public HashJoinMechanicalMemoryCalculator(int maxNumInMemBatches)

Method Details

initialize

public void initialize(boolean doMemoryCalc)

Specified by:

initialize in interface HashJoinMemoryCalculator

next

@Nullable
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: