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

Class AbstractHashBinaryRecordBatch.Updater

java.lang.Object

org.apache.drill.exec.physical.impl.join.AbstractHashBinaryRecordBatch.Updater

All Implemented Interfaces:

SpilledState.Updater

Enclosing class:

AbstractHashBinaryRecordBatch<T extends PhysicalOperator>

public class AbstractHashBinaryRecordBatch.Updater
extends Object
implements SpilledState.Updater

Constructor Summary

Constructors

Constructor	Description
Updater()

Method Summary

Modifier and Type	Method	Description
void	cleanup()	Does any necessary cleanup if we've spilled too much and abort the query.
String	getFailureMessage()	Gets the failure message in the event that we spilled to far.
long	getMemLimit()	Gets the current memory limit.
boolean	hasPartitionLimit()	True if there is a limit to the number of times we can partition.

Methods inherited from class java.lang.Object

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

Constructor Details

Updater

public Updater()

Method Details

cleanup

public void cleanup()

Description copied from interface: SpilledState.Updater

Does any necessary cleanup if we've spilled too much and abort the query.

Specified by:

cleanup in interface SpilledState.Updater

getFailureMessage

public String getFailureMessage()

Description copied from interface: SpilledState.Updater

Gets the failure message in the event that we spilled to far.

Specified by:

getFailureMessage in interface SpilledState.Updater

Returns:

The failure message in the event that we spilled to far.

getMemLimit

public long getMemLimit()

Description copied from interface: SpilledState.Updater

Gets the current memory limit.

Specified by:

getMemLimit in interface SpilledState.Updater

Returns:

The current memory limit.

hasPartitionLimit

public boolean hasPartitionLimit()

Description copied from interface: SpilledState.Updater

True if there is a limit to the number of times we can partition.

Specified by:

hasPartitionLimit in interface SpilledState.Updater

Returns:

True if there is a limit to the number of times we can partition.