public class ExecutorsListener extends SparkListener
Constructor and Description |
---|
ExecutorsListener(StorageStatusListener storageStatusListener,
SparkConf conf)
Deprecated.
|
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
|
onApplicationEnd, onBlockManagerAdded, onBlockManagerRemoved, onBlockUpdated, onEnvironmentUpdate, onExecutorMetricsUpdate, onJobEnd, onJobStart, onOtherEvent, onStageCompleted, onStageSubmitted, onTaskGettingResult, onUnpersistRDD
public ExecutorsListener(StorageStatusListener storageStatusListener, SparkConf conf)
public scala.collection.mutable.LinkedHashMap<String,org.apache.spark.ui.exec.ExecutorTaskSummary> executorToTaskSummary()
public scala.collection.mutable.ListBuffer<SparkListenerEvent> executorEvents()
public scala.collection.Seq<StorageStatus> activeStorageStatusList()
public scala.collection.Seq<StorageStatus> deadStorageStatusList()
public void onExecutorAdded(SparkListenerExecutorAdded executorAdded)
onExecutorAdded
in class SparkListener
executorAdded
- (undocumented)public void onExecutorRemoved(SparkListenerExecutorRemoved executorRemoved)
onExecutorRemoved
in class SparkListener
executorRemoved
- (undocumented)public void onApplicationStart(SparkListenerApplicationStart applicationStart)
onApplicationStart
in class SparkListener
applicationStart
- (undocumented)public void onTaskStart(SparkListenerTaskStart taskStart)
onTaskStart
in class SparkListener
taskStart
- (undocumented)public void onTaskEnd(SparkListenerTaskEnd taskEnd)
onTaskEnd
in class SparkListener
taskEnd
- (undocumented)public void onExecutorBlacklisted(SparkListenerExecutorBlacklisted executorBlacklisted)
onExecutorBlacklisted
in class SparkListener
executorBlacklisted
- (undocumented)public void onExecutorUnblacklisted(SparkListenerExecutorUnblacklisted executorUnblacklisted)
onExecutorUnblacklisted
in class SparkListener
executorUnblacklisted
- (undocumented)public void onNodeBlacklisted(SparkListenerNodeBlacklisted nodeBlacklisted)
onNodeBlacklisted
in class SparkListener
nodeBlacklisted
- (undocumented)public void onNodeUnblacklisted(SparkListenerNodeUnblacklisted nodeUnblacklisted)
onNodeUnblacklisted
in class SparkListener
nodeUnblacklisted
- (undocumented)