public static class UIData.StageUIData
extends Object
Constructor and Description |
---|
UIData.StageUIData() |
Modifier and Type | Method and Description |
---|---|
scala.collection.mutable.HashMap<Object,AccumulableInfo> |
accumulables() |
org.apache.spark.util.collection.OpenHashSet<Object> |
completedIndices() |
scala.Option<String> |
description() |
long |
diskBytesSpilled() |
long |
executorRunTime() |
scala.collection.mutable.HashMap<String,UIData.ExecutorSummary> |
executorSummary() |
long |
inputBytes() |
long |
memoryBytesSpilled() |
int |
numActiveTasks() |
int |
numCompleteTasks() |
int |
numFailedTasks() |
long |
outputBytes() |
String |
schedulingPool() |
long |
shuffleReadBytes() |
long |
shuffleWriteBytes() |
scala.collection.mutable.HashMap<Object,UIData.TaskUIData> |
taskData() |
public int numActiveTasks()
public int numCompleteTasks()
public org.apache.spark.util.collection.OpenHashSet<Object> completedIndices()
public int numFailedTasks()
public long executorRunTime()
public long inputBytes()
public long outputBytes()
public long shuffleReadBytes()
public long shuffleWriteBytes()
public long memoryBytesSpilled()
public long diskBytesSpilled()
public String schedulingPool()
public scala.Option<String> description()
public scala.collection.mutable.HashMap<Object,AccumulableInfo> accumulables()
public scala.collection.mutable.HashMap<Object,UIData.TaskUIData> taskData()
public scala.collection.mutable.HashMap<String,UIData.ExecutorSummary> executorSummary()