窗口() 函数

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 选项。

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)