SparkStreaming的運行流程解析（源碼）

ssc.start() 啓動receiverTracker.start去獲取數據 啓動jobGenerator.start去計算數據 receiverTracker.start   在這裏的receiverinputStreams其實已經實例化了。在inputDStream的時候已經往ssc.graph中添加了實例(具體去看下我的Sparkstreaming中InputDStream的詳解（源碼）

>>阅读原文<<