derivative() 函数

derivative() 计算后续非空记录之间每单位时间的更改率。

该函数假定行按 _time 排序。

输出表

输出表模式将与输入表相同。对于每个具有 n 行的输入表，derivative() 输出一个具有 n - 1 行的表。

函数类型签名

(
    <-tables: stream[A],
    ?columns: [string],
    ?initialZero: bool,
    ?nonNegative: bool,
    ?timeColumn: string,
    ?unit: duration,
) => stream[B] where A: Record, B: Record

参数

unit

用于计算导数的持续时间。默认为 1s。

nonNegative

不允许负导数值。默认为 false。

当 true 时，如果值小于前一个值，则该函数假定前一个值应为零。

columns

要操作的列列表。默认为 ["_value"]。

timeColumn

包含用于计算的时间值的列。默认为 _time。

initialZero

当后续值小于前一个值且 nonNegative 为 true 时，使用零 (0) 作为导数计算中的初始值。默认为 false。

tables

输入数据。默认为管道转发数据 (<-)。

示例

• 计算每秒的非负变化率
• 计算包含空值的每秒变化率

计算每秒的非负变化率

import "sampledata"

sampledata.int()
    |> derivative(nonNegative: true)

计算包含空值的每秒变化率

import "sampledata"

sampledata.int(includeNull: true)
    |> derivative()