timeWeightedAvg() function

timeWeightedAvg() returns the time-weighted average of non-null values in _value column as a float for each input table.

Time is weighted using the linearly interpolated integral of values in the table.

Function type signature

(<-tables: stream[A], unit: duration) => stream[{B with _value: float, _value: float, _stop: D, _start: C}] where A: Record

Parameters

unit

(Required) Unit of time to use to compute the time-weighted average.

tables

Input data. Default is piped-forward data (<-).

Examples

Calculate the time-weighted average of values

data
    |> timeWeightedAvg(unit: 1s)