SparkStream源碼分析：JobScheduler的JobStarted、JobCompleted是怎麼被調用的

一，從StreamingContext.start()進入 ===>在SparkContext有一個JobScheduler成員會被初始化，JobScheduler會被StreamingContext.start()被調用 private[streaming]valscheduler =newJobScheduler(this) 二，跟進入JobScheduler的start（）方法，發現JobS

>>阅读原文<<