public class ExecutorsListener extends Object implements SparkListener
| Constructor and Description |
|---|
ExecutorsListener(StorageStatusListener storageStatusListener) |
| Modifier and Type | Method and Description |
|---|---|
scala.collection.mutable.HashMap<String,Object> |
executorToDuration() |
scala.collection.mutable.HashMap<String,Object> |
executorToShuffleRead() |
scala.collection.mutable.HashMap<String,Object> |
executorToShuffleWrite() |
scala.collection.mutable.HashMap<String,Object> |
executorToTasksActive() |
scala.collection.mutable.HashMap<String,Object> |
executorToTasksComplete() |
scala.collection.mutable.HashMap<String,Object> |
executorToTasksFailed() |
void |
onTaskEnd(SparkListenerTaskEnd taskEnd)
Called when a task ends
|
void |
onTaskStart(SparkListenerTaskStart taskStart)
Called when a task starts
|
scala.collection.Seq<StorageStatus> |
storageStatusList() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonApplicationEnd, onApplicationStart, onBlockManagerAdded, onBlockManagerRemoved, onEnvironmentUpdate, onJobEnd, onJobStart, onStageCompleted, onStageSubmitted, onTaskGettingResult, onUnpersistRDDpublic ExecutorsListener(StorageStatusListener storageStatusListener)
public scala.collection.mutable.HashMap<String,Object> executorToTasksActive()
public scala.collection.mutable.HashMap<String,Object> executorToTasksComplete()
public scala.collection.mutable.HashMap<String,Object> executorToTasksFailed()
public scala.collection.mutable.HashMap<String,Object> executorToDuration()
public scala.collection.mutable.HashMap<String,Object> executorToShuffleRead()
public scala.collection.mutable.HashMap<String,Object> executorToShuffleWrite()
public scala.collection.Seq<StorageStatus> storageStatusList()
public void onTaskStart(SparkListenerTaskStart taskStart)
SparkListeneronTaskStart in interface SparkListenerpublic void onTaskEnd(SparkListenerTaskEnd taskEnd)
SparkListeneronTaskEnd in interface SparkListener