SparkStreaming是如何完成不停的循環處理的代碼淺析

一直很好奇Sparkstreaming的ssc.start是怎麼作到不停的一直定時循環處理數據的， 看了一下源碼， 大體明白了整個過程， 記錄分享一下。 入口爲StreamingContext的start方法： 在構造StreamingContext的時候 state就初始化爲INITIALIZED ， 而且定義了一個JobScheduler scheduler 代碼裏面很明白， 在初始化的時候，

>>阅读原文<<