Spark Streaming執行流程源碼剖析

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