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

Class HashJoinMechanicalMemoryCalculator.MechanicalPostBuildCalculations

java.lang.Object

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

All Implemented Interfaces:

HashJoinMemoryCalculator.PostBuildCalculations, HashJoinStateCalculator<HashJoinMemoryCalculator>

Enclosing class:

HashJoinMechanicalMemoryCalculator

public static class HashJoinMechanicalMemoryCalculator.MechanicalPostBuildCalculations
extends Object
implements HashJoinMemoryCalculator.PostBuildCalculations

Constructor Summary

Constructors

Constructor	Description
MechanicalPostBuildCalculations(int maxNumInMemBatches, HashJoinMemoryCalculator.PartitionStatSet partitionStatSet, int recordsPerPartitionBatchProbe)

Method Summary

Modifier and Type	Method	Description
int	getProbeRecordsPerBatch()
HashJoinState	getState()	The current HashJoinState corresponding to this calculator.
void	initialize(boolean probeEmty)	Initializes the calculator with additional information needed.
String	makeDebugString()
HashJoinMemoryCalculator	next()	Signifies that the current state is complete and returns the next HashJoinStateCalculator.
boolean	shouldSpill()

Methods inherited from class java.lang.Object

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

Constructor Details

MechanicalPostBuildCalculations

public MechanicalPostBuildCalculations(int maxNumInMemBatches,
 HashJoinMemoryCalculator.PartitionStatSet partitionStatSet,
 int recordsPerPartitionBatchProbe)

Method Details

initialize

public void initialize(boolean probeEmty)

Description copied from interface: HashJoinMemoryCalculator.PostBuildCalculations

Initializes the calculator with additional information needed.

Specified by:

initialize in interface HashJoinMemoryCalculator.PostBuildCalculations

Parameters:

probeEmty - True if the probe is empty. False otherwise.

getProbeRecordsPerBatch

public int getProbeRecordsPerBatch()

Specified by:

getProbeRecordsPerBatch in interface HashJoinMemoryCalculator.PostBuildCalculations

shouldSpill

public boolean shouldSpill()

Specified by:

shouldSpill in interface HashJoinMemoryCalculator.PostBuildCalculations

makeDebugString

public String makeDebugString()

Specified by:

makeDebugString in interface HashJoinMemoryCalculator.PostBuildCalculations

next

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

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>

Returns: