一起学习Spark（六）结构化流Structured Streaming编程指南（2）-窗口函数

本篇主要内容是Spark Structured Streaming实现事件时间的窗口操作。 滑动事件时间窗口的聚合操作对于Structured Streaming非常简单，与分组聚合非常相似。在分组聚合中，会按照用户的指定的一个或多个列进行分组，再为用户指定的分组列中的每个惟一值维护聚合值(例如计数)，对于基于窗口的聚合，为每一个事件时间所在的窗口维护聚合值。让我们用一个例子来理解它。 比如现在我

>>阅读原文<<