子流
子流不是物理流,仅在查询时可用。
你可以为流创建 子流,也可以为特定主键创建 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 分钟)。