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

Class HashJoinMemoryCalculatorImpl.NoopPostBuildCalculationsImpl

java.lang.Object

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

All Implemented Interfaces:

HashJoinMemoryCalculator.PostBuildCalculations, HashJoinStateCalculator<HashJoinMemoryCalculator>

Enclosing class:

HashJoinMemoryCalculatorImpl

public static class HashJoinMemoryCalculatorImpl.NoopPostBuildCalculationsImpl
extends Object
implements HashJoinMemoryCalculator.PostBuildCalculations

Constructor Summary

Constructors

Constructor	Description
NoopPostBuildCalculationsImpl(int recordsPerPartitionBatchProbe)

Method Summary

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

NoopPostBuildCalculationsImpl

public NoopPostBuildCalculationsImpl(int recordsPerPartitionBatchProbe)

Method Details

initialize

public void initialize(boolean hasProbeData)

Description copied from interface: HashJoinMemoryCalculator.PostBuildCalculations

Initializes the calculator with additional information needed.

Specified by:

initialize in interface HashJoinMemoryCalculator.PostBuildCalculations

Parameters:

hasProbeData - 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

next

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:

makeDebugString

public String makeDebugString()

Specified by:

makeDebugString in interface HashJoinMemoryCalculator.PostBuildCalculations