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

Interface SpilledState.Updater

All Known Implementing Classes:
AbstractHashBinaryRecordBatch.Updater, HashAggUpdater
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
    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 Details

    • 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.