本文为您介绍如何使用 Spark SQL 流式处理中的滚动窗口函数。

什么是滚动窗口

滚动窗口(TUMBLING)将每个元素分配到一个指定大小的窗口中。通常滚动窗口有一个固定的大小,并且不会出现重叠。例如,如果指定了一个 5 分钟大小的滚动窗口,无限流的数据会根据时间划分成 [0:00 - 0:05)、 [0:05, 0:10)、[0:10, 0:15) 等窗口。

语法

GROUP BY TUMBLING ( colName, windowDuration ) 

示例

SELECT avg(inv_quantity_on_hand) qoh
FROM kafka_inventory
GROUP BY TUMBLING (inv_data_time, interval 1 minute)