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() |
boolean |
hasBytesSpilled() |
boolean |
hasInput() |
boolean |
hasOutput() |
boolean |
hasShuffleRead() |
boolean |
hasShuffleWrite() |
long |
inputBytes() |
long |
inputRecords() |
long |
memoryBytesSpilled() |
int |
numActiveTasks() |
int |
numCompleteTasks() |
int |
numFailedTasks() |
long |
outputBytes() |
long |
outputRecords() |
String |
schedulingPool() |
long |
shuffleReadRecords() |
long |
shuffleReadTotalBytes() |
long |
shuffleWriteBytes() |
long |
shuffleWriteRecords() |
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 inputRecords()
public long outputBytes()
public long outputRecords()
public long shuffleReadTotalBytes()
public long shuffleReadRecords()
public long shuffleWriteBytes()
public long shuffleWriteRecords()
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()
public boolean hasInput()
public boolean hasOutput()
public boolean hasShuffleRead()
public boolean hasShuffleWrite()
public boolean hasBytesSpilled()