本文为您介绍如何使用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)