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

Class HashAggUpdater

java.lang.Object

org.apache.drill.exec.physical.impl.aggregate.HashAggUpdater

All Implemented Interfaces:

SpilledState.Updater

public class HashAggUpdater
extends Object
implements SpilledState.Updater

Constructor Summary

Constructors

Constructor	Description
HashAggUpdater(BufferAllocator allocator)

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

HashAggUpdater

public HashAggUpdater(BufferAllocator allocator)

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.