Spark學習筆記(24)StreamingContext及JobScheduler源碼圖解

本期內容: 1. StreamingContext啓動源碼圖解 2. JobScheduler啓動源碼圖解 StreamingContext的start方法對INITIALIZED、ACTIVE、STOPPED等狀態分別做不同處理。 StreamingContext在INITIALIZED狀態時,用validate方法對DStreamGraph、checkpoint等做有效檢查,然後啓動新的線程設
相關文章
相關標籤/搜索