大數據學習日誌——解析sparkstreaming滑動窗口源碼

寫這篇隨筆的原因在於本人在網上看了很多相關博客很多文章內容給出的用法都一致是如下形式：  1 reduceByKeyAndWindow(_ + _,_ - _,Minutes(2),Seconds(10),2)  但是詳細描述函數的各個參數怎麼使用，爲什麼要怎麼寫，可以怎麼修改參數的文章基本沒看到。於是便想着自己動手豐衣足食，從源碼粗略看起來，這個滑動窗口到底怎麼用！spark2.4版本 本內容主

>>阅读原文<<