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

Class HashJoinMemoryCalculatorImpl.NoopBuildSidePartitioningImpl

java.lang.Object

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

All Implemented Interfaces:

HashJoinMemoryCalculator.BuildSidePartitioning, HashJoinStateCalculator<HashJoinMemoryCalculator.PostBuildCalculations>

Enclosing class:

HashJoinMemoryCalculatorImpl

public static class HashJoinMemoryCalculatorImpl.NoopBuildSidePartitioningImpl
extends Object
implements HashJoinMemoryCalculator.BuildSidePartitioning

Constructor Summary

Constructors

Constructor	Description
NoopBuildSidePartitioningImpl()

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 firstCycle, 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

NoopBuildSidePartitioningImpl

public NoopBuildSidePartitioningImpl()

Method Details

initialize

public void initialize(boolean firstCycle,
 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

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: