public class StageData
extends Object
public scala.collection.Seq<AccumulableInfo> accumulatorUpdates()
public int attemptId()
public scala.Option<java.util.Date> completionTime()
public scala.Option<String> description()
public String details()
public long diskBytesSpilled()
public long executorCpuTime()
public long executorDeserializeCpuTime()
public long executorDeserializeTime()
public long executorRunTime()
public scala.Option<scala.collection.immutable.Map<String,ExecutorStageSummary>> executorSummary()
public scala.Option<String> failureReason()
public scala.Option<java.util.Date> firstTaskLaunchedTime()
public long inputBytes()
public long inputRecords()
public long jvmGcTime()
public scala.collection.immutable.Map<String,Object> killedTasksSummary()
public long memoryBytesSpilled()
public String name()
public int numActiveTasks()
public int numCompleteTasks()
public int numCompletedIndices()
public int numFailedTasks()
public int numKilledTasks()
public int numTasks()
public long outputBytes()
public long outputRecords()
public long peakExecutionMemory()
public scala.Option<org.apache.spark.executor.ExecutorMetrics> peakExecutorMetrics()
public scala.collection.Seq<Object> rddIds()
public int resourceProfileId()
public long resultSerializationTime()
public long resultSize()
public String schedulingPool()
public long shuffleFetchWaitTime()
public long shuffleLocalBlocksFetched()
public long shuffleLocalBytesRead()
public long shuffleReadBytes()
public long shuffleReadRecords()
public long shuffleRemoteBlocksFetched()
public long shuffleRemoteBytesRead()
public long shuffleRemoteBytesReadToDisk()
public long shuffleWriteBytes()
public long shuffleWriteRecords()
public long shuffleWriteTime()
public int stageId()
public StageStatus status()
public scala.Option<java.util.Date> submissionTime()
public scala.Option<scala.collection.immutable.Map<Object,TaskData>> tasks()