跳转至主要内容

子流

子流不是物理流,仅在查询时可用。

你可以为流创建子流,也可以为特定主键创建 tumble/hop/session 窗口,以维护单独的水印和流窗口。

例如:

SELECT window_start, window_end, cid, count(*), max(speed_kmh)
FROM session(car_live_data, 1m) PARTITION BY cid
GROUP BY window_start, window_end

它将为每辆车创建 session 窗口,空闲时间为1分钟。 表示汽车未在一分钟内移动, 窗口将被关闭,并将为未来事件创建一个新的会话窗口。 如果车辆持续行驶超过 5 分钟,则会创建不同的窗户(每 5 分钟)。