SparkFirehoseListener
Related Doc:
package spark
Called when the application ends
Called when the application ends
Called when the application starts
Called when the application starts
Called when a new block manager has joined
Called when a new block manager has joined
Called when an existing block manager has been removed
Called when an existing block manager has been removed
Called when the driver receives a block update info.
Called when the driver receives a block update info.
Called when environment properties have been updated
Called when environment properties have been updated
Called when the driver registers a new executor.
Called when the driver registers a new executor.
Called when the driver receives task metrics from an executor in a heartbeat.
Called when the driver receives task metrics from an executor in a heartbeat.
Called when the driver removes an executor.
Called when the driver removes an executor.
Called when a job ends
Called when a job ends
Called when a job starts
Called when a job starts
Called when other events like SQL-specific events are posted.
Called when other events like SQL-specific events are posted.
Called when a stage completes successfully or fails, with information on the completed stage.
Called when a stage completes successfully or fails, with information on the completed stage.
Called when a stage is submitted
Called when a stage is submitted
Called when a task ends
Called when a task ends
Called when a task begins remotely fetching its result (will not be called for tasks that do not need to fetch the result remotely).
Called when a task begins remotely fetching its result (will not be called for tasks that do not need to fetch the result remotely).
Called when a task starts
Called when a task starts
Called when an RDD is manually unpersisted by the application
Called when an RDD is manually unpersisted by the application