aggregate.window() is a user-contributed function maintained by
the package author and can
be updated or removed at any time.
aggregate.window() aggregates columns and create tables by
organizing incoming points into windows.
Each table will have two additional columns: start and stop. These are the start and stop times for each interval. It is not possible to use start or stop as destination column names with this function. The start and stop columns are not added to the group key.
Function type signature
( <-tables: stream[B], columns: A, every: duration, ?period: duration, ?time: string, ) => stream[C] where A: Record, B: Record, C: Record
Input data. Default is piped-forward data (
Columns to aggregate and which aggregate method to use. See
aggregate.table() for details.
(Required) Duration between the start of each interval.
Column name for the time input. Defaults to
time (whichever is earlier in the list of columns).
Length of the interval. Defaults to the
Was this page helpful?
Thank you for your feedback!
Support and feedback
Thank you for being part of our community! We welcome and encourage your feedback and bug reports for Flux and this documentation. To find support, use the following resources:
InfluxDB Cloud customers can contact InfluxData Support.