SparkListenerSQLExecutionEnd¶

SparkListenerSQLExecutionEnd is a SparkListenerEvent (Spark Core).

SparkListenerSQLExecutionEnd is posted (to an event bus) to announce that SQLExecution has completed executing a structured query.

Creating Instance¶

SparkListenerSQLExecutionEnd takes the following to be created:

• Execution ID
• Timestamp

SparkListenerSQLExecutionEnd is created when:

• SQLExecution is requested to withNewExecutionId

Execution ID¶

SparkListenerSQLExecutionEnd is given executionId when created.

The execution ID is the next available execution ID when SQLExecution is requested to withNewExecutionId.

Timestamp¶

SparkListenerSQLExecutionEnd is given a timestamp when created.

The timestamp is the time when SQLExecution has finished withNewExecutionId.

SparkListener.onOtherEvent¶

SparkListenerSQLExecutionEnd can be intercepted using SparkListener.onOtherEvent (Spark Core).

SparkListeners¶

The following SparkListeners intercepts SparkListenerSQLExecutionEnds:

• SQLEventFilterBuilder
• SQLAppStatusListener

QueryExecutionListeners¶

SparkListenerSQLExecutionEnd is posted to QueryExecutionListeners using ExecutionListenerBus.