public class ExecutorsListener extends java.lang.Object implements SparkListener
Constructor and Description |
---|
ExecutorsListener(StorageStatusListener storageStatusListener) |
Modifier and Type | Method and Description |
---|---|
scala.collection.mutable.HashMap<java.lang.String,org.apache.spark.ui.jobs.UIData.ExecutorUIData> |
executorIdToData() |
scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> |
executorToDuration() |
scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> |
executorToInputBytes() |
scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> |
executorToInputRecords() |
scala.collection.mutable.HashMap<java.lang.String,scala.collection.immutable.Map<java.lang.String,java.lang.String>> |
executorToLogUrls() |
scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> |
executorToOutputBytes() |
scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> |
executorToOutputRecords() |
scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> |
executorToShuffleRead() |
scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> |
executorToShuffleWrite() |
scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> |
executorToTasksActive() |
scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> |
executorToTasksComplete() |
scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> |
executorToTasksFailed() |
void |
onApplicationStart(SparkListenerApplicationStart applicationStart)
Called when the application starts
|
void |
onExecutorAdded(SparkListenerExecutorAdded executorAdded)
Called when the driver registers a new executor.
|
void |
onExecutorRemoved(SparkListenerExecutorRemoved executorRemoved)
Called when the driver removes an executor.
|
void |
onTaskEnd(SparkListenerTaskEnd taskEnd)
Called when a task ends
|
void |
onTaskStart(SparkListenerTaskStart taskStart)
Called when a task starts
|
scala.collection.Seq<StorageStatus> |
storageStatusList() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onApplicationEnd, onBlockManagerAdded, onBlockManagerRemoved, onBlockUpdated, onEnvironmentUpdate, onExecutorMetricsUpdate, onJobEnd, onJobStart, onStageCompleted, onStageSubmitted, onTaskGettingResult, onUnpersistRDD
public ExecutorsListener(StorageStatusListener storageStatusListener)
public scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> executorToTasksActive()
public scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> executorToTasksComplete()
public scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> executorToTasksFailed()
public scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> executorToDuration()
public scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> executorToInputBytes()
public scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> executorToInputRecords()
public scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> executorToOutputBytes()
public scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> executorToOutputRecords()
public scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> executorToShuffleRead()
public scala.collection.mutable.HashMap<java.lang.String,java.lang.Object> executorToShuffleWrite()
public scala.collection.mutable.HashMap<java.lang.String,scala.collection.immutable.Map<java.lang.String,java.lang.String>> executorToLogUrls()
public scala.collection.mutable.HashMap<java.lang.String,org.apache.spark.ui.jobs.UIData.ExecutorUIData> executorIdToData()
public scala.collection.Seq<StorageStatus> storageStatusList()
public void onExecutorAdded(SparkListenerExecutorAdded executorAdded)
SparkListener
onExecutorAdded
in interface SparkListener
executorAdded
- (undocumented)public void onExecutorRemoved(SparkListenerExecutorRemoved executorRemoved)
SparkListener
onExecutorRemoved
in interface SparkListener
executorRemoved
- (undocumented)public void onApplicationStart(SparkListenerApplicationStart applicationStart)
SparkListener
onApplicationStart
in interface SparkListener
applicationStart
- (undocumented)public void onTaskStart(SparkListenerTaskStart taskStart)
SparkListener
onTaskStart
in interface SparkListener
taskStart
- (undocumented)public void onTaskEnd(SparkListenerTaskEnd taskEnd)
SparkListener
onTaskEnd
in interface SparkListener
taskEnd
- (undocumented)