Spark Streaming工做流程源碼解析

這篇文章以Spark官方Word Count爲例，基於最新的2.0.2版本代碼淺析Spark Streaming 的工做流程，這個例子實現了對socket流中的單詞進行採集，以秒爲單位統計每秒種出現的單詞及出現次數。Word Count代碼中路徑以下： /spark/examples/src/main/scala/org/apache/spark/examples/streaming/Networ

>>阅读原文<<