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