org.apache.spark.status.api.v1
Class StageData
Object
org.apache.spark.status.api.v1.StageData
public class StageData
- extends Object
Methods inherited from class Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
status
public StageStatus status()
stageId
public int stageId()
attemptId
public int attemptId()
numActiveTasks
public int numActiveTasks()
numCompleteTasks
public int numCompleteTasks()
numFailedTasks
public int numFailedTasks()
executorRunTime
public long executorRunTime()
inputBytes
public long inputBytes()
inputRecords
public long inputRecords()
outputBytes
public long outputBytes()
outputRecords
public long outputRecords()
shuffleReadBytes
public long shuffleReadBytes()
shuffleReadRecords
public long shuffleReadRecords()
shuffleWriteBytes
public long shuffleWriteBytes()
shuffleWriteRecords
public long shuffleWriteRecords()
memoryBytesSpilled
public long memoryBytesSpilled()
diskBytesSpilled
public long diskBytesSpilled()
name
public String name()
details
public String details()
schedulingPool
public String schedulingPool()
accumulatorUpdates
public scala.collection.Seq<AccumulableInfo> accumulatorUpdates()
tasks
public scala.Option<scala.collection.Map<Object,TaskData>> tasks()
executorSummary
public scala.Option<scala.collection.Map<String,ExecutorStageSummary>> executorSummary()