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 StageStatus status()
public int stageId()
public int attemptId()
public int numTasks()
public int numActiveTasks()
public int numCompleteTasks()
public int numFailedTasks()
public int numKilledTasks()
public int numCompletedIndices()
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 scala.Option<String> failureReason()
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 scala.Option<String> description()
public String details()
public String schedulingPool()
public scala.collection.Seq<Object> rddIds()
public scala.collection.Seq<AccumulableInfo> accumulatorUpdates()
public scala.Option<scala.collection.immutable.Map<Object,TaskData>> tasks()
public scala.Option<scala.collection.immutable.Map<String,ExecutorStageSummary>> executorSummary()
public scala.collection.immutable.Map<String,Object> killedTasksSummary()