public class StageData
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<AccumulableInfo> |
accumulatorUpdates() |
int |
attemptId() |
java.lang.String |
details() |
long |
diskBytesSpilled() |
long |
executorRunTime() |
scala.Option<scala.collection.Map<java.lang.String,ExecutorStageSummary>> |
executorSummary() |
long |
inputBytes() |
long |
inputRecords() |
long |
memoryBytesSpilled() |
java.lang.String |
name() |
int |
numActiveTasks() |
int |
numCompleteTasks() |
int |
numFailedTasks() |
long |
outputBytes() |
long |
outputRecords() |
java.lang.String |
schedulingPool() |
long |
shuffleReadBytes() |
long |
shuffleReadRecords() |
long |
shuffleWriteBytes() |
long |
shuffleWriteRecords() |
int |
stageId() |
StageStatus |
status() |
scala.Option<scala.collection.Map<java.lang.Object,TaskData>> |
tasks() |
public StageStatus status()
public int stageId()
public int attemptId()
public int numActiveTasks()
public int numCompleteTasks()
public int numFailedTasks()
public long executorRunTime()
public long inputBytes()
public long inputRecords()
public long outputBytes()
public long outputRecords()
public long shuffleReadBytes()
public long shuffleReadRecords()
public long shuffleWriteBytes()
public long shuffleWriteRecords()
public long memoryBytesSpilled()
public long diskBytesSpilled()
public java.lang.String name()
public java.lang.String details()
public java.lang.String schedulingPool()
public scala.collection.Seq<AccumulableInfo> accumulatorUpdates()
public scala.Option<scala.collection.Map<java.lang.Object,TaskData>> tasks()
public scala.Option<scala.collection.Map<java.lang.String,ExecutorStageSummary>> executorSummary()