Spark原理篇之Spark Streaming轉化操作和輸出操作

1 轉化操作       DStream的轉化操作可以分爲無狀態和有狀態兩種。       ① 在無狀態轉化操作中，每個批次的處理不依賴於之前批次的數據。例如map()、filter()和reduceByKey()等都是無狀態轉化操作。       ② 有狀態轉化操作需要使用之前批次的數據或者是中間結果來計算當前批次的數據。有狀態轉化操作包括基於滑動窗口的轉化操作和追蹤狀態變化的轉化操作。 1.1

>>阅读原文<<