org.apache.spark.ui.exec
Class ExecutorsListener

Object
  org.apache.spark.ui.exec.ExecutorsListener

All Implemented Interfaces:

SparkListener

public class ExecutorsListener
extends Object
implements SparkListener

:: 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

ExecutorsListener

public ExecutorsListener(StorageStatusListener storageStatusListener)

Method Detail

executorToTasksActive

public scala.collection.mutable.HashMap<String,Object> executorToTasksActive()

executorToTasksComplete

public scala.collection.mutable.HashMap<String,Object> executorToTasksComplete()

executorToTasksFailed

public scala.collection.mutable.HashMap<String,Object> executorToTasksFailed()

executorToDuration

public scala.collection.mutable.HashMap<String,Object> executorToDuration()

executorToInputBytes

public scala.collection.mutable.HashMap<String,Object> executorToInputBytes()

executorToInputRecords

public scala.collection.mutable.HashMap<String,Object> executorToInputRecords()

executorToOutputBytes

public scala.collection.mutable.HashMap<String,Object> executorToOutputBytes()

executorToOutputRecords

public scala.collection.mutable.HashMap<String,Object> executorToOutputRecords()

executorToShuffleRead

public scala.collection.mutable.HashMap<String,Object> executorToShuffleRead()

executorToShuffleWrite

public scala.collection.mutable.HashMap<String,Object> executorToShuffleWrite()

executorToLogUrls

public scala.collection.mutable.HashMap<String,scala.collection.immutable.Map<String,String>> executorToLogUrls()

executorIdToData

public scala.collection.mutable.HashMap<String,org.apache.spark.ui.jobs.UIData.ExecutorUIData> executorIdToData()

storageStatusList

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

onExecutorAdded

public void onExecutorAdded(SparkListenerExecutorAdded executorAdded)

Description copied from interface: SparkListener

Called when the driver registers a new executor.

Specified by:

onExecutorAdded in interface SparkListener

Parameters:

executorAdded - (undocumented)

onExecutorRemoved

public void onExecutorRemoved(SparkListenerExecutorRemoved executorRemoved)

Description copied from interface: SparkListener

Called when the driver removes an executor.

Specified by:

onExecutorRemoved in interface SparkListener

Parameters:

executorRemoved - (undocumented)

onTaskStart

public void onTaskStart(SparkListenerTaskStart taskStart)

Description copied from interface: SparkListener

Called when a task starts

Specified by:

onTaskStart in interface SparkListener

Parameters:

taskStart - (undocumented)

onTaskEnd

public void onTaskEnd(SparkListenerTaskEnd taskEnd)

Description copied from interface: SparkListener

Called when a task ends

Specified by:

onTaskEnd in interface SparkListener

Parameters:

taskEnd - (undocumented)