Skip to content

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:

Back to top