Spark Streaming工做流程源码解析

这篇文章以Spark官方Word Count为例，基于最新的2.0.2版本代码浅析Spark Streaming 的工做流程，这个例子实现了对socket流中的单词进行采集，以秒为单位统计每秒种出现的单词及出现次数。Word Count代码中路径以下： /spark/examples/src/main/scala/org/apache/spark/examples/streaming/Networ

>>阅读原文<<