|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Object org.apache.spark.ui.exec.ExecutorsListener
public class ExecutorsListener
:: DeveloperApi :: A SparkListener that prepares information to be displayed on the ExecutorsTab
Constructor Summary | |
---|---|
ExecutorsListener(StorageStatusListener storageStatusListener)
|
Method Summary | |
---|---|
scala.collection.mutable.HashMap<String,org.apache.spark.ui.jobs.UIData.ExecutorUIData> |
executorIdToData()
|
scala.collection.mutable.HashMap<String,Object> |
executorToDuration()
|
scala.collection.mutable.HashMap<String,Object> |
executorToInputBytes()
|
scala.collection.mutable.HashMap<String,Object> |
executorToInputRecords()
|
scala.collection.mutable.HashMap<String,scala.collection.immutable.Map<String,String>> |
executorToLogUrls()
|
scala.collection.mutable.HashMap<String,Object> |
executorToOutputBytes()
|
scala.collection.mutable.HashMap<String,Object> |
executorToOutputRecords()
|
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 |
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()
|
Methods inherited from class Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.spark.scheduler.SparkListener |
---|
onApplicationEnd, onApplicationStart, onBlockManagerAdded, onBlockManagerRemoved, onEnvironmentUpdate, onExecutorMetricsUpdate, onJobEnd, onJobStart, onStageCompleted, onStageSubmitted, onTaskGettingResult, onUnpersistRDD |
Constructor Detail |
---|
public ExecutorsListener(StorageStatusListener storageStatusListener)
Method Detail |
---|
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> executorToInputBytes()
public scala.collection.mutable.HashMap<String,Object> executorToInputRecords()
public scala.collection.mutable.HashMap<String,Object> executorToOutputBytes()
public scala.collection.mutable.HashMap<String,Object> executorToOutputRecords()
public scala.collection.mutable.HashMap<String,Object> executorToShuffleRead()
public scala.collection.mutable.HashMap<String,Object> executorToShuffleWrite()
public scala.collection.mutable.HashMap<String,scala.collection.immutable.Map<String,String>> executorToLogUrls()
public scala.collection.mutable.HashMap<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 onTaskStart(SparkListenerTaskStart taskStart)
SparkListener
onTaskStart
in interface SparkListener
taskStart
- (undocumented)public void onTaskEnd(SparkListenerTaskEnd taskEnd)
SparkListener
onTaskEnd
in interface SparkListener
taskEnd
- (undocumented)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |