-
Notifications
You must be signed in to change notification settings - Fork 25.6k
Add time bucket to time-series rate aggregation #126010
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
e975a0e
to
1d9543d
Compare
1d9543d
to
2746d98
Compare
2746d98
to
e972f91
Compare
Pinging @elastic/es-analytical-engine (Team:Analytics) |
Pinging @elastic/es-storage-engine (Team:StorageEngine) |
|
||
public TimeSeriesAggregate(StreamInput in) throws IOException { | ||
super(in); | ||
this.timeBucket = in.readOptionalWriteable(inp -> (Bucket) Bucket.ENTRY.reader.read(inp)); |
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.
Does this need to be versioned?
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.
I disabled time_series tests in mixed clusters to allow us to move quickly here.
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.
This is fine for now. We'll eventually want to pass the interval as an arg to rate
and agg_over_time
functions, or as a second arg to TBUCKET
, but we can look at that later.
Thanks Kostas! |
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.
LGTM2
We need the bucket interval within the rate function to perform extrapolation. With this change, along with elastic#26089, we will be able to pass the grouping range interval to rate aggregations.
We need the bucket interval within the rate function to perform extrapolation. With this change, along with #26089, we will be able to pass the grouping range interval to rate aggregations.