Module org.elasticsearch.compute
Class GroupingAggregator
java.lang.Object
org.elasticsearch.compute.aggregation.GroupingAggregator
- All Implemented Interfaces:
Closeable,AutoCloseable,org.elasticsearch.core.Releasable
-
Nested Class Summary
Nested Classes -
Constructor Summary
ConstructorsConstructorDescriptionGroupingAggregator(GroupingAggregatorFunction aggregatorFunction, AggregatorMode mode) -
Method Summary
Modifier and TypeMethodDescriptionvoidaddIntermediateRow(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 positionvoidclose()voidevaluate(Block[] blocks, int offset, IntVector selected, DriverContext driverContext) Build the results for this aggregation.intThe number of Blocks required for evaluation.prepareProcessPage(SeenGroupIds seenGroupIds, Page page) Prepare to process a single page of results.toString()
-
Constructor Details
-
GroupingAggregator
-
-
Method Details
-
evaluateBlockCount
public int evaluateBlockCount()The number of Blocks required for evaluation. -
prepareProcessPage
Prepare to process a single page of results. -
addIntermediateRow
Add the position-th row from the intermediate output of the given aggregator to this aggregator at the groupId position -
evaluate
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:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceorg.elasticsearch.core.Releasable
-
toString
-