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

Class HashJoinMechanicalMemoryCalculator.MechanicalBuildSidePartitioning

java.lang.Object

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

All Implemented Interfaces:

HashJoinMemoryCalculator.BuildSidePartitioning, HashJoinStateCalculator<HashJoinMemoryCalculator.PostBuildCalculations>

Enclosing class:

HashJoinMechanicalMemoryCalculator

public static class HashJoinMechanicalMemoryCalculator.MechanicalBuildSidePartitioning
extends Object
implements HashJoinMemoryCalculator.BuildSidePartitioning

Constructor Summary

Constructors

Constructor	Description
MechanicalBuildSidePartitioning(int maxNumInMemBatches)

Method Summary

Modifier and Type	Method	Description
long	getBuildReservedMemory()
long	getMaxReservedMemory()
int	getNumPartitions()
HashJoinState	getState()	The current HashJoinState corresponding to this calculator.
void	initialize(boolean autoTune, boolean reserveHash, RecordBatch buildSideBatch, RecordBatch probeSideBatch, Set<String> joinColumns, boolean probeEmpty, long memoryAvailable, int initialPartitions, int recordsPerPartitionBatchBuild, int recordsPerPartitionBatchProbe, int maxBatchNumRecordsBuild, int maxBatchNumRecordsProbe, int outputBatchSize, double loadFactor)
String	makeDebugString()
HashJoinMemoryCalculator.PostBuildCalculations	next()	Signifies that the current state is complete and returns the next HashJoinStateCalculator.
void	setPartitionStatSet(HashJoinMemoryCalculator.PartitionStatSet partitionStatSet)
boolean	shouldSpill()

Methods inherited from class java.lang.Object

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

Constructor Details

MechanicalBuildSidePartitioning

public MechanicalBuildSidePartitioning(int maxNumInMemBatches)

Method Details

initialize

public void initialize(boolean autoTune,
 boolean reserveHash,
 RecordBatch buildSideBatch,
 RecordBatch probeSideBatch,
 Set<String> joinColumns,
 boolean probeEmpty,
 long memoryAvailable,
 int initialPartitions,
 int recordsPerPartitionBatchBuild,
 int recordsPerPartitionBatchProbe,
 int maxBatchNumRecordsBuild,
 int maxBatchNumRecordsProbe,
 int outputBatchSize,
 double loadFactor)

Specified by:

initialize in interface HashJoinMemoryCalculator.BuildSidePartitioning

setPartitionStatSet

public void setPartitionStatSet(HashJoinMemoryCalculator.PartitionStatSet partitionStatSet)

Specified by:

setPartitionStatSet in interface HashJoinMemoryCalculator.BuildSidePartitioning

getNumPartitions

public int getNumPartitions()

Specified by:

getNumPartitions in interface HashJoinMemoryCalculator.BuildSidePartitioning

getBuildReservedMemory

public long getBuildReservedMemory()

Specified by:

getBuildReservedMemory in interface HashJoinMemoryCalculator.BuildSidePartitioning

getMaxReservedMemory

public long getMaxReservedMemory()

Specified by:

getMaxReservedMemory in interface HashJoinMemoryCalculator.BuildSidePartitioning

shouldSpill

public boolean shouldSpill()

Specified by:

shouldSpill in interface HashJoinMemoryCalculator.BuildSidePartitioning

makeDebugString

public String makeDebugString()

Specified by:

makeDebugString in interface HashJoinMemoryCalculator.BuildSidePartitioning

next

@Nullable
public HashJoinMemoryCalculator.PostBuildCalculations 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.PostBuildCalculations>

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.PostBuildCalculations>

Returns: