timedMovingAverage() function
timedMovingAverage()
returns the mean of values in a defined time range at a
specified frequency.
For each row in a table, timedMovingAverage()
returns the average of the
current value and all row values in the previous period
(duration).
It returns moving averages at a frequency defined by the every
parameter.
Aggregate by calendar months and years
every
and period
parameters support all valid duration units, including
calendar months (1mo
) and years (1y
).
Aggregate by week
When aggregating by week (1w
), weeks are determined using the Unix epoch
(1970-01-01T00:00:00Z UTC). The Unix epoch was on a Thursday, so all
calculated weeks begin on Thursday.
Function type signature
(<-tables: stream[A], every: duration, period: duration, ?column: string) => stream[B] where A: Record, B: Record
Parameters
every
(Required) Frequency of time window.
period
(Required) Length of each averaged time window.
A negative duration indicates start and stop boundaries are reversed.
column
Column to operate on. Default is _value
.
tables
Input data. Default is piped-forward data (<-
).
Examples
Calculate a five year moving average every year
data
|> timedMovingAverage(every: 1y, period: 5y)
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:
Customers with an annual or support contract can contact InfluxData Support.