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