org.apache.spark.ui.exec

Class ExecutorsListener

Object

org.apache.spark.scheduler.SparkListener

org.apache.spark.ui.exec.ExecutorsListener

Deprecated.

This class will be removed in a future release. Since 2.2.0.

public class ExecutorsListener
extends SparkListener

:: DeveloperApi :: A SparkListener that prepares information to be displayed on the ExecutorsTab

Constructor Summary

Constructors

Constructor and Description
ExecutorsListener(StorageStatusListener storageStatusListener, SparkConf conf) Deprecated.

Method Summary

Modifier and Type	Method and Description
scala.collection.Seq<StorageStatus>	activeStorageStatusList() Deprecated.
scala.collection.Seq<StorageStatus>	deadStorageStatusList() Deprecated.
scala.collection.mutable.ListBuffer<SparkListenerEvent>	executorEvents() Deprecated.
scala.collection.mutable.LinkedHashMap<String,org.apache.spark.ui.exec.ExecutorTaskSummary>	executorToTaskSummary() Deprecated.
void	onApplicationStart(SparkListenerApplicationStart applicationStart) Deprecated. Called when the application starts
void	onExecutorAdded(SparkListenerExecutorAdded executorAdded) Deprecated. Called when the driver registers a new executor.
void	onExecutorBlacklisted(SparkListenerExecutorBlacklisted executorBlacklisted) Deprecated. Called when the driver blacklists an executor for a Spark application.
void	onExecutorRemoved(SparkListenerExecutorRemoved executorRemoved) Deprecated. Called when the driver removes an executor.
void	onExecutorUnblacklisted(SparkListenerExecutorUnblacklisted executorUnblacklisted) Deprecated. Called when the driver re-enables a previously blacklisted executor.
void	onNodeBlacklisted(SparkListenerNodeBlacklisted nodeBlacklisted) Deprecated. Called when the driver blacklists a node for a Spark application.
void	onNodeUnblacklisted(SparkListenerNodeUnblacklisted nodeUnblacklisted) Deprecated. Called when the driver re-enables a previously blacklisted node.
void	onTaskEnd(SparkListenerTaskEnd taskEnd) Deprecated. Called when a task ends
void	onTaskStart(SparkListenerTaskStart taskStart) Deprecated. Called when a task starts

Methods inherited from class org.apache.spark.scheduler.SparkListener

onApplicationEnd, onBlockManagerAdded, onBlockManagerRemoved, onBlockUpdated, onEnvironmentUpdate, onExecutorMetricsUpdate, onJobEnd, onJobStart, onOtherEvent, onStageCompleted, onStageSubmitted, onTaskGettingResult, onUnpersistRDD

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExecutorsListener

public ExecutorsListener(StorageStatusListener storageStatusListener,
                         SparkConf conf)

Deprecated.

Method Detail

executorToTaskSummary

public scala.collection.mutable.LinkedHashMap<String,org.apache.spark.ui.exec.ExecutorTaskSummary> executorToTaskSummary()

Deprecated.

executorEvents

public scala.collection.mutable.ListBuffer<SparkListenerEvent> executorEvents()

Deprecated.

activeStorageStatusList

public scala.collection.Seq<StorageStatus> activeStorageStatusList()

Deprecated.

deadStorageStatusList

public scala.collection.Seq<StorageStatus> deadStorageStatusList()

Deprecated.

onExecutorAdded

public void onExecutorAdded(SparkListenerExecutorAdded executorAdded)

Deprecated.

Called when the driver registers a new executor.

Overrides:

onExecutorAdded in class SparkListener

Parameters:

executorAdded - (undocumented)

onExecutorRemoved

public void onExecutorRemoved(SparkListenerExecutorRemoved executorRemoved)

Deprecated.

Called when the driver removes an executor.

Overrides:

onExecutorRemoved in class SparkListener

Parameters:

executorRemoved - (undocumented)

onApplicationStart

public void onApplicationStart(SparkListenerApplicationStart applicationStart)

Deprecated.

Called when the application starts

Overrides:

onApplicationStart in class SparkListener

Parameters:

applicationStart - (undocumented)

onTaskStart

public void onTaskStart(SparkListenerTaskStart taskStart)

Deprecated.

Called when a task starts

Overrides:

onTaskStart in class SparkListener

Parameters:

taskStart - (undocumented)

onTaskEnd

public void onTaskEnd(SparkListenerTaskEnd taskEnd)

Deprecated.

Called when a task ends

Overrides:

onTaskEnd in class SparkListener

Parameters:

taskEnd - (undocumented)

onExecutorBlacklisted

public void onExecutorBlacklisted(SparkListenerExecutorBlacklisted executorBlacklisted)

Deprecated.

Called when the driver blacklists an executor for a Spark application.

Overrides:

onExecutorBlacklisted in class SparkListener

Parameters:

executorBlacklisted - (undocumented)

onExecutorUnblacklisted

public void onExecutorUnblacklisted(SparkListenerExecutorUnblacklisted executorUnblacklisted)

Deprecated.

Called when the driver re-enables a previously blacklisted executor.

Overrides:

onExecutorUnblacklisted in class SparkListener

Parameters:

executorUnblacklisted - (undocumented)

onNodeBlacklisted

public void onNodeBlacklisted(SparkListenerNodeBlacklisted nodeBlacklisted)

Deprecated.

Called when the driver blacklists a node for a Spark application.

Overrides:

onNodeBlacklisted in class SparkListener

Parameters:

nodeBlacklisted - (undocumented)

onNodeUnblacklisted

public void onNodeUnblacklisted(SparkListenerNodeUnblacklisted nodeUnblacklisted)

Deprecated.

Called when the driver re-enables a previously blacklisted node.

Overrides:

onNodeUnblacklisted in class SparkListener

Parameters:

nodeUnblacklisted - (undocumented)