tickscript.selectWindow() 函数

tickscript.selectWindow() 更改列名，按时间窗口化行，然后为每个时间窗口对指定列应用聚合或选择器函数。

TICKscript 辅助函数

tickscript.selectWindow 是一个旨在复制如下 TICKscript 操作的辅助函数

// Rename, window, and aggregate
query("SELECT f(x) AS y")
  .groupBy(time(t), ...)

函数类型签名

(
    <-tables: stream[D],
    as: string,
    defaultValue: A,
    every: duration,
    fn: (<-: stream[B], column: string) => stream[C],
    ?column: string,
) => stream[E] where B: Record, C: Record, D: Record, E: Record

参数

column

要操作的列。默认为 _value。

fn

（必需）要应用的聚合或选择器函数。

as

（必需）新列名。

every

（必需）窗口的持续时间。

defaultValue

（必需）列中空值的默认填充值。必须与列的数据类型相同。

tables

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

示例

更改名称、窗口化，然后聚合 value 列

import "contrib/bonitoo-io/tickscript"

data
    |> tickscript.selectWindow(fn: sum, as: "example-name", every: 1h, defaultValue: 0)