window!

Author: dnhatn

docs/reference/query-languages/esql/_snippets/functions/parameters/rate.md

@@ -0,0 +1 @@
+9203000

docs/reference/query-languages/esql/_snippets/functions/types/rate.md

@@ -1 +1 @@
-min_transport_version,9202000
+aggregation_window,9203000

docs/reference/query-languages/esql/images/functions/rate.svg

@@ -18,19 +18,15 @@
 
 import java.util.function.Function;
 
-public class GroupingAggregator implements Releasable {
-    private final GroupingAggregatorFunction aggregatorFunction;
+public record GroupingAggregator(GroupingAggregatorFunction aggregatorFunction, AggregatorMode mode) implements Releasable {
 
-    private final AggregatorMode mode;
+    public interface Factory extends Function<DriverContext, GroupingAggregator>, Describable {
 
-    public interface Factory extends Function<DriverContext, GroupingAggregator>, Describable {}
-
-    public GroupingAggregator(GroupingAggregatorFunction aggregatorFunction, AggregatorMode mode) {
-        this.aggregatorFunction = aggregatorFunction;
-        this.mode = mode;
     }
 
-    /** The number of Blocks required for evaluation. */
+    /**
+     * The number of Blocks required for evaluation.
+     */
     public int evaluateBlockCount() {
         return mode.isOutputPartial() ? aggregatorFunction.intermediateBlockCount() : 1;
     }

server/src/main/resources/transport/definitions/referable/aggregation_window.csv

@@ -9,6 +9,8 @@
 
 import org.elasticsearch.compute.operator.DriverContext;
 
+import java.util.List;
+
 public abstract class TimeSeriesGroupingAggregatorEvaluationContext extends GroupingAggregatorEvaluationContext {
     public TimeSeriesGroupingAggregatorEvaluationContext(DriverContext driverContext) {
         super(driverContext);
@@ -17,4 +19,7 @@ public TimeSeriesGroupingAggregatorEvaluationContext(DriverContext driverContext
     public abstract long rangeStartInMillis(int groupId);
 
     public abstract long rangeEndInMillis(int groupId);
+
+    public abstract List<Integer> groupIdsFromWindow(int groupId, long windowInterval);
+
 }