window() 函数

window() 使用规则的时间间隔对记录进行分组。

此函数计算时间窗口并将窗口边界存储在 _start 和 _stop 列中。 _start 和 _stop 值根据行的 _time 值分配给行。

单个输入行可以放入零个或多个输出表中，具体取决于传递到 window() 的参数。

此函数旨在在 timeColumn（默认为 _time）不在组键中使用时使用。如果 timeColumn在组键中，则生成的输出令人困惑且通常无用。

按日历月和年划分窗口

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

按周划分窗口

当按周 (1w) 划分窗口时，周是使用 Unix 纪元 (1970-01-01T00:00:00Z UTC) 确定的。Unix 纪元是在星期四，因此所有计算的周都从星期四开始。

函数类型签名

(
    <-tables: stream[A],
    ?createEmpty: bool,
    ?every: duration,
    ?location: {zone: string, offset: duration},
    ?offset: duration,
    ?period: duration,
    ?startColumn: string,
    ?stopColumn: string,
    ?timeColumn: string,
) => stream[B] where A: Record, B: Record

参数

every

窗口之间的时间间隔持续时间。

period

窗口的持续时间。默认为 every 值。

period 可以为负数，表示开始和停止边界已反转。

offset

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

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

location

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

timeColumn

包含时间值的列。默认为 _time。

startColumn

存储窗口开始时间的列。默认为 _start。

stopColumn

存储窗口停止时间的列。默认为 _stop。

createEmpty

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

tables

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

示例

• 将数据窗口化为 30 秒间隔
• 每 20 秒窗口化一次，覆盖 40 秒周期
• 按日历月划分窗口

将数据窗口化为 30 秒间隔

data
    |> window(every: 30s)

每 20 秒窗口化一次，覆盖 40 秒周期

data
    |> window(every: 20s, period: 40s)

按日历月划分窗口

data
    |> window(every: 1mo)