Structured Streaming和flink的watermark

Structured Streaming和flink都支持流式操作，支持對亂序數據的處理，都引入了watermark的概念，watermark都是系統能處理的亂序數據的最早的時間，但二者的具體表現也不盡相同。 1、Structured Streaming的watermark機制 (a+) 在對 event time 做 window() + groupBy().aggregation() 即利用狀

>>阅读原文<<