Spark Streaming執行流程源碼剖析

1、StreamingContext初始化過程 在Spark Streaming中使用StreamingContext來操做DStream，這也比如Spark Core中SparkContext對於RDD，DStream能夠說是RDD的又一層封裝，做用於DStream上的Operation能夠大概分爲如下兩類：java Transformation轉換操做。 Output表示輸出結果，主要有pri

>>阅读原文<<