elastic · dnhatn · Jul 11, 2025 · Jul 2, 2025
diff --git a/...ompute/gen/src/main/java/org/elasticsearch/compute/gen/GroupingAggregatorImplementer.java b/...ompute/gen/src/main/java/org/elasticsearch/compute/gen/GroupingAggregatorImplementer.java
@@ -199,7 +199,7 @@ private TypeSpec type() {
         builder.addMethod(ctor());
         builder.addMethod(intermediateStateDesc());
         builder.addMethod(intermediateBlockCount());
-        builder.addMethod(prepareProcessPage());
+        builder.addMethod(prepareProcessRawInputPage());
         for (ClassName groupIdClass : GROUP_IDS_CLASSES) {
             builder.addMethod(addRawInputLoop(groupIdClass, blockType(aggParam.type())));
             builder.addMethod(addRawInputLoop(groupIdClass, vectorType(aggParam.type())));
@@ -314,10 +314,10 @@ private MethodSpec intermediateBlockCount() {
     }
 
     /**
-     * Prepare to process a single page of results.
+     * Prepare to process a single raw input page.
      */
-    private MethodSpec prepareProcessPage() {
-        MethodSpec.Builder builder = MethodSpec.methodBuilder("prepareProcessPage");
+    private MethodSpec prepareProcessRawInputPage() {
+        MethodSpec.Builder builder = MethodSpec.methodBuilder("prepareProcessRawInputPage");
         builder.addAnnotation(Override.class).addModifiers(Modifier.PUBLIC).returns(GROUPING_AGGREGATOR_FUNCTION_ADD_INPUT);
         builder.addParameter(SEEN_GROUP_IDS, "seenGroupIds").addParameter(PAGE, "page");
 

diff --git a/...org/elasticsearch/compute/aggregation/CountDistinctBooleanGroupingAggregatorFunction.java b/...org/elasticsearch/compute/aggregation/CountDistinctBooleanGroupingAggregatorFunction.java
diff --git a/...rg/elasticsearch/compute/aggregation/CountDistinctBytesRefGroupingAggregatorFunction.java b/...rg/elasticsearch/compute/aggregation/CountDistinctBytesRefGroupingAggregatorFunction.java
diff --git a/.../org/elasticsearch/compute/aggregation/CountDistinctDoubleGroupingAggregatorFunction.java b/.../org/elasticsearch/compute/aggregation/CountDistinctDoubleGroupingAggregatorFunction.java
diff --git a/...d/org/elasticsearch/compute/aggregation/CountDistinctFloatGroupingAggregatorFunction.java b/...d/org/elasticsearch/compute/aggregation/CountDistinctFloatGroupingAggregatorFunction.java
diff --git a/...ted/org/elasticsearch/compute/aggregation/CountDistinctIntGroupingAggregatorFunction.java b/...ted/org/elasticsearch/compute/aggregation/CountDistinctIntGroupingAggregatorFunction.java
diff --git a/...ed/org/elasticsearch/compute/aggregation/CountDistinctLongGroupingAggregatorFunction.java b/...ed/org/elasticsearch/compute/aggregation/CountDistinctLongGroupingAggregatorFunction.java
diff --git a/.../org/elasticsearch/compute/aggregation/FirstOverTimeDoubleGroupingAggregatorFunction.java b/.../org/elasticsearch/compute/aggregation/FirstOverTimeDoubleGroupingAggregatorFunction.java
diff --git a/...d/org/elasticsearch/compute/aggregation/FirstOverTimeFloatGroupingAggregatorFunction.java b/...d/org/elasticsearch/compute/aggregation/FirstOverTimeFloatGroupingAggregatorFunction.java
diff --git a/...ted/org/elasticsearch/compute/aggregation/FirstOverTimeIntGroupingAggregatorFunction.java b/...ted/org/elasticsearch/compute/aggregation/FirstOverTimeIntGroupingAggregatorFunction.java
diff --git a/...ed/org/elasticsearch/compute/aggregation/FirstOverTimeLongGroupingAggregatorFunction.java b/...ed/org/elasticsearch/compute/aggregation/FirstOverTimeLongGroupingAggregatorFunction.java
diff --git a/...d/org/elasticsearch/compute/aggregation/LastOverTimeDoubleGroupingAggregatorFunction.java b/...d/org/elasticsearch/compute/aggregation/LastOverTimeDoubleGroupingAggregatorFunction.java
diff --git a/...ed/org/elasticsearch/compute/aggregation/LastOverTimeFloatGroupingAggregatorFunction.java b/...ed/org/elasticsearch/compute/aggregation/LastOverTimeFloatGroupingAggregatorFunction.java
diff --git a/...ated/org/elasticsearch/compute/aggregation/LastOverTimeIntGroupingAggregatorFunction.java b/...ated/org/elasticsearch/compute/aggregation/LastOverTimeIntGroupingAggregatorFunction.java
diff --git a/...ted/org/elasticsearch/compute/aggregation/LastOverTimeLongGroupingAggregatorFunction.java b/...ted/org/elasticsearch/compute/aggregation/LastOverTimeLongGroupingAggregatorFunction.java
diff --git a/...generated/org/elasticsearch/compute/aggregation/MaxBooleanGroupingAggregatorFunction.java b/...generated/org/elasticsearch/compute/aggregation/MaxBooleanGroupingAggregatorFunction.java
diff --git a/...enerated/org/elasticsearch/compute/aggregation/MaxBytesRefGroupingAggregatorFunction.java b/...enerated/org/elasticsearch/compute/aggregation/MaxBytesRefGroupingAggregatorFunction.java
diff --git a/.../generated/org/elasticsearch/compute/aggregation/MaxDoubleGroupingAggregatorFunction.java b/.../generated/org/elasticsearch/compute/aggregation/MaxDoubleGroupingAggregatorFunction.java
diff --git a/...n/generated/org/elasticsearch/compute/aggregation/MaxFloatGroupingAggregatorFunction.java b/...n/generated/org/elasticsearch/compute/aggregation/MaxFloatGroupingAggregatorFunction.java
diff --git a/...ain/generated/org/elasticsearch/compute/aggregation/MaxIntGroupingAggregatorFunction.java b/...ain/generated/org/elasticsearch/compute/aggregation/MaxIntGroupingAggregatorFunction.java
diff --git a/...main/generated/org/elasticsearch/compute/aggregation/MaxIpGroupingAggregatorFunction.java b/...main/generated/org/elasticsearch/compute/aggregation/MaxIpGroupingAggregatorFunction.java
diff --git a/...in/generated/org/elasticsearch/compute/aggregation/MaxLongGroupingAggregatorFunction.java b/...in/generated/org/elasticsearch/compute/aggregation/MaxLongGroupingAggregatorFunction.java
diff --git a/...icsearch/compute/aggregation/MedianAbsoluteDeviationDoubleGroupingAggregatorFunction.java b/...icsearch/compute/aggregation/MedianAbsoluteDeviationDoubleGroupingAggregatorFunction.java
diff --git a/...ticsearch/compute/aggregation/MedianAbsoluteDeviationFloatGroupingAggregatorFunction.java b/...ticsearch/compute/aggregation/MedianAbsoluteDeviationFloatGroupingAggregatorFunction.java
diff --git a/...asticsearch/compute/aggregation/MedianAbsoluteDeviationIntGroupingAggregatorFunction.java b/...asticsearch/compute/aggregation/MedianAbsoluteDeviationIntGroupingAggregatorFunction.java
diff --git a/...sticsearch/compute/aggregation/MedianAbsoluteDeviationLongGroupingAggregatorFunction.java b/...sticsearch/compute/aggregation/MedianAbsoluteDeviationLongGroupingAggregatorFunction.java
diff --git a/...generated/org/elasticsearch/compute/aggregation/MinBooleanGroupingAggregatorFunction.java b/...generated/org/elasticsearch/compute/aggregation/MinBooleanGroupingAggregatorFunction.java
diff --git a/...enerated/org/elasticsearch/compute/aggregation/MinBytesRefGroupingAggregatorFunction.java b/...enerated/org/elasticsearch/compute/aggregation/MinBytesRefGroupingAggregatorFunction.java
diff --git a/.../generated/org/elasticsearch/compute/aggregation/MinDoubleGroupingAggregatorFunction.java b/.../generated/org/elasticsearch/compute/aggregation/MinDoubleGroupingAggregatorFunction.java
diff --git a/...n/generated/org/elasticsearch/compute/aggregation/MinFloatGroupingAggregatorFunction.java b/...n/generated/org/elasticsearch/compute/aggregation/MinFloatGroupingAggregatorFunction.java
diff --git a/...ain/generated/org/elasticsearch/compute/aggregation/MinIntGroupingAggregatorFunction.java b/...ain/generated/org/elasticsearch/compute/aggregation/MinIntGroupingAggregatorFunction.java
diff --git a/...main/generated/org/elasticsearch/compute/aggregation/MinIpGroupingAggregatorFunction.java b/...main/generated/org/elasticsearch/compute/aggregation/MinIpGroupingAggregatorFunction.java
diff --git a/...in/generated/org/elasticsearch/compute/aggregation/MinLongGroupingAggregatorFunction.java b/...in/generated/org/elasticsearch/compute/aggregation/MinLongGroupingAggregatorFunction.java
diff --git a/...ted/org/elasticsearch/compute/aggregation/PercentileDoubleGroupingAggregatorFunction.java b/...ted/org/elasticsearch/compute/aggregation/PercentileDoubleGroupingAggregatorFunction.java
diff --git a/...ated/org/elasticsearch/compute/aggregation/PercentileFloatGroupingAggregatorFunction.java b/...ated/org/elasticsearch/compute/aggregation/PercentileFloatGroupingAggregatorFunction.java
diff --git a/...erated/org/elasticsearch/compute/aggregation/PercentileIntGroupingAggregatorFunction.java b/...erated/org/elasticsearch/compute/aggregation/PercentileIntGroupingAggregatorFunction.java
diff --git a/...rated/org/elasticsearch/compute/aggregation/PercentileLongGroupingAggregatorFunction.java b/...rated/org/elasticsearch/compute/aggregation/PercentileLongGroupingAggregatorFunction.java
diff --git a/...generated/org/elasticsearch/compute/aggregation/RateDoubleGroupingAggregatorFunction.java b/...generated/org/elasticsearch/compute/aggregation/RateDoubleGroupingAggregatorFunction.java
diff --git a/.../generated/org/elasticsearch/compute/aggregation/RateFloatGroupingAggregatorFunction.java b/.../generated/org/elasticsearch/compute/aggregation/RateFloatGroupingAggregatorFunction.java
diff --git a/...in/generated/org/elasticsearch/compute/aggregation/RateIntGroupingAggregatorFunction.java b/...in/generated/org/elasticsearch/compute/aggregation/RateIntGroupingAggregatorFunction.java
diff --git a/...n/generated/org/elasticsearch/compute/aggregation/RateLongGroupingAggregatorFunction.java b/...n/generated/org/elasticsearch/compute/aggregation/RateLongGroupingAggregatorFunction.java
diff --git a/...erated/org/elasticsearch/compute/aggregation/SampleBooleanGroupingAggregatorFunction.java b/...erated/org/elasticsearch/compute/aggregation/SampleBooleanGroupingAggregatorFunction.java