Skip to content

Commit 9e57f6c

Browse files
committed
Add comment
1 parent 375e045 commit 9e57f6c

File tree

5 files changed

+10
-0
lines changed

5 files changed

+10
-0
lines changed

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/aggregation/LastOverTimeDoubleAggregator.java

Lines changed: 2 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/aggregation/LastOverTimeFloatAggregator.java

Lines changed: 2 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/aggregation/LastOverTimeIntAggregator.java

Lines changed: 2 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/aggregation/LastOverTimeLongAggregator.java

Lines changed: 2 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/X-LastOverTimeAggregator.java.st

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,8 @@ public class LastOverTime$Type$Aggregator {
3737
return new GroupingState(driverContext.bigArrays());
3838
}
3939

40+
// TODO: Since data in data_streams is sorted by `_tsid` and timestamp in descending order,
41+
// we can read the first encountered value for each group of `_tsid` and time bucket.
4042
public static void combine(GroupingState current, int groupId, long timestamp, $type$ value) {
4143
current.collectValue(groupId, timestamp, value);
4244
}

0 commit comments

Comments
 (0)