Structured Streaming和flink的watermark

Structured Streaming和flink都支持流式操作，支持对乱序数据的处理，都引入了watermark的概念，watermark都是系统能处理的乱序数据的最早的时间，但二者的具体表现也不尽相同。 1、Structured Streaming的watermark机制 (a+) 在对 event time 做 window() + groupBy().aggregation() 即利用状

>>阅读原文<<