ListenerBus¶

ListenerBus is an abstraction of event buses that can notify listeners about scheduling events.

Contract¶

Notifying Listener about Event¶

doPostEvent(
  listener: L,
  event: E): Unit

Used when ListenerBus is requested to postToAll

Implementations¶

• ExecutionListenerBus
• ExternalCatalogWithListener
• SparkListenerBus
• StreamingListenerBus
• StreamingQueryListenerBus

Posting Event To All Listeners¶

postToAll(
  event: E): Unit

postToAll...FIXME

postToAll is used when:

• AsyncEventQueue is requested to dispatch an event
• ReplayListenerBus is requested to replay events

Registering Listener¶

addListener(
  listener: L): Unit

addListener...FIXME

addListener is used when:

• LiveListenerBus is requested to addToQueue
• EventLogFileCompactor is requested to initializeBuilders
• FsHistoryProvider is requested to doMergeApplicationListing and rebuildAppStore