深入理解Spark之ListenerBus监听器
ListenerBus对消费队列的实现 上图为LiveListenerBus类的申明 self => 这句相当于给this起了一个别名为selfLiveListenerBus负责将SparkListenerEvents异步发送过已经注册过的SparkListeners,在SparkContext中,首先会创建LiveListenerBus实例,这个类的功能是保存有消息队列负责消息的缓存保存有