ExecutionListenerBus¶

ExecutionListenerBus is a ListenerBus (Spark Core) that notifies registered QueryExecutionListeners aboutSparkListenerSQLExecutionEnd events.

ExecutionListenerBus is a SparkListener (Spark Core).

Creating Instance¶

ExecutionListenerBus takes the following to be created:

• ExecutionListenerManager
• SparkSession or Session ID

ExecutionListenerBus is created when:

• ExecutionListenerManager is created

Intercepting Other Events¶

onOtherEvent(
  event: SparkListenerEvent): Unit

onOtherEvent is part of the SparkListenerInterface (Spark Core) abstraction.

onOtherEvent post the given SparkListenerSQLExecutionEnd to all registered QueryExecutionListeners.

Notifying QueryExecutionListener about SparkListenerSQLExecutionEnd¶

doPostEvent(
  listener: QueryExecutionListener,
  event: SparkListenerSQLExecutionEnd): Unit

doPostEvent is part of the ListenerBus (Spark Core) abstraction.

doPostEvent...FIXME