org.apache.drill.exec.physical.impl.common

Interface SpilledState.Updater

All Known Implementing Classes:

HashAggUpdater, HashJoinBatch.HashJoinUpdater

Enclosing class:

SpilledState<T extends SpilledPartitionMetadata>

public static interface SpilledState.Updater

This is a class that is used to do updates of the spilled state.

Method Summary

Modifier and Type	Method and 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.

Method Detail

cleanup

void cleanup()

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

getFailureMessage

String getFailureMessage()

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

Returns:

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

getMemLimit

long getMemLimit()

Gets the current memory limit.

Returns:

The current memory limit.

hasPartitionLimit

boolean hasPartitionLimit()

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

Returns:

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