Class GroupingAggregator

java.lang.Object
org.elasticsearch.compute.aggregation.GroupingAggregator
All Implemented Interfaces:
Closeable, AutoCloseable, org.elasticsearch.core.Releasable

public class GroupingAggregator extends Object implements org.elasticsearch.core.Releasable
  • Constructor Details

  • Method Details

    • evaluateBlockCount

      public int evaluateBlockCount()
      The number of Blocks required for evaluation.
    • prepareProcessPage

      public GroupingAggregatorFunction.AddInput prepareProcessPage(SeenGroupIds seenGroupIds, Page page)
      Prepare to process a single page of results.
    • addIntermediateRow

      public void addIntermediateRow(int groupId, GroupingAggregator input, int position)
      Add the position-th row from the intermediate output of the given aggregator to this aggregator at the groupId position
    • evaluate

      public void evaluate(Block[] blocks, int offset, IntVector selected, DriverContext driverContext)
      Build the results for this aggregation.
      Parameters:
      selected - the groupIds that have been selected to be included in the results. Always ascending.
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.elasticsearch.core.Releasable
    • toString

      public String toString()
      Overrides:
      toString in class Object