experimental.window() 函数

experimental.window() 根据时间对记录进行分组。

_start 和 _stop 列已更新，以反映行的时间值所在的窗口边界。输入表必须具有 _start、_stop 和 _time 列。

单个输入记录可以放入零个或多个输出表中，具体取决于特定的窗口函数。

默认情况下，窗口的开始边界将与 Unix 纪元对齐，并由 location 选项的偏移量进行修改。

日历月和年

every、period 和 offset 支持所有有效的持续时间单位，包括日历月 (1mo) 和年 (1y)。

函数类型签名

(
    <-tables: stream[{A with _time: time, _stop: time, _start: time}],
    ?createEmpty: bool,
    ?every: duration,
    ?location: {zone: string, offset: duration},
    ?offset: duration,
    ?period: duration,
) => stream[{A with _time: time, _stop: time, _start: time}]

参数

every

窗口之间的时间间隔。默认为 0s。

period

窗口的持续时间。默认为 0s。

Period 是每个间隔的长度。它可以为负，表示开始和停止边界已反转。

offset

窗口边界偏移的持续时间。默认为 0s。

offset 可以为负，表示偏移在时间上向后退。

location

用于确定时区的 Location。默认为 location 选项。

createEmpty

为空窗口创建空表。默认为 false。

tables

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

示例

• 将数据窗口化为三十秒间隔
• 按日历月窗口化

将数据窗口化为三十秒间隔

import "experimental"

data
    |> experimental.window(every: 30s)

按日历月窗口化

import "experimental"

data
    |> experimental.window(every: 1mo)