SparkStreaming滑動計算窗口reduceByKeyAndWindow圖解說明

對於reduceByKeyAndWindow(_ + _, _ - _,Second(45), Second(5))這種算法不太明白的同學可以參考下，下圖是通過個人理解所畫，希望對大家理解這個函數有所幫助： 首先，說一下需求，就是每隔5秒，計算過去45秒內的X數量。 第一個窗口（第一個45s內,時間點1）裏面的X數量是17個，然後時間往後移動了5秒，變成了時間點2。 圖中，在時間滑動後，新增了5個

>>阅读原文<<