-
Notifications
You must be signed in to change notification settings - Fork 25.6k
Add logical/physical plans time-series aggregate #126178
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
483d153 to
4a4472c
Compare
4a4472c to
ec52b30
Compare
|
Pinging @elastic/es-analytical-engine (Team:Analytics) |
|
Pinging @elastic/es-storage-engine (Team:StorageEngine) |
martijnvg
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks like we need to update TelemetryIT (TIME_SERIES is now replaced by STATS), but otherwise LGTM
We need to store extra information for Aggregate and AggregateExec for time-series aggregations.
Just for my own information, what additional information are we planning to store?
.../java/org/elasticsearch/xpack/esql/optimizer/rules/logical/TranslateTimeSeriesAggregate.java
Show resolved
Hide resolved
.../java/org/elasticsearch/xpack/esql/optimizer/rules/logical/TranslateTimeSeriesAggregate.java
Outdated
Show resolved
Hide resolved
...plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plan/logical/TimeSeriesAggregate.java
Show resolved
Hide resolved
kkrik-es
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Just a few minor comments.
We need to store the time bucket for extrapolation in rate aggregation. |
|
@martijnvg @kkrik-es Thanks for the review! |
We need to store extra information for Aggregate and AggregateExec for time-series aggregations. Previously, I added a type (standard or time_series), but this was not enough. This PR removes it and replaces it with extensions of Aggregate and AggregateExec. I considered adding an extra map of metadata to Aggregate and AggregateExec, but this approach seems simpler.
We need to store extra information for Aggregate and AggregateExec for time-series aggregations. Previously, I added a type (standard or time_series), but this was not enough. This PR removes it and replaces it with extensions of Aggregate and AggregateExec. I considered adding an extra map of metadata to Aggregate and AggregateExec, but this approach seems simpler.