Spark Streaming执行流程源码剖析

1、StreamingContext初始化过程 在Spark Streaming中使用StreamingContext来操做DStream，这也比如Spark Core中SparkContext对于RDD，DStream能够说是RDD的又一层封装，做用于DStream上的Operation能够大概分为如下两类：java Transformation转换操做。 Output表示输出结果，主要有pri

>>阅读原文<<