深入理解Spark之ListenerBus監聽器

ListenerBus對消費隊列的實現 上圖爲LiveListenerBus類的申明 self => 這句相當於給this起了一個別名爲self LiveListenerBus負責將SparkListenerEvents異步發送過已經註冊過的SparkListeners,在SparkContext中，首先會創建LiveListenerBus實例，這個類的功能是 保存有消息隊列負責消息的緩存 保存有

>>阅读原文<<