public class ExecutorStageSummary
extends Object
Modifier and Type | Method and Description |
---|---|
long |
diskBytesSpilled() |
int |
failedTasks() |
long |
inputBytes() |
long |
inputRecords() |
boolean |
isBlacklistedForStage()
Deprecated.
use isExcludedForStage instead. Since 3.1.0.
|
boolean |
isExcludedForStage() |
int |
killedTasks() |
long |
memoryBytesSpilled() |
long |
outputBytes() |
long |
outputRecords() |
scala.Option<org.apache.spark.executor.ExecutorMetrics> |
peakMemoryMetrics() |
long |
shuffleRead() |
long |
shuffleReadRecords() |
long |
shuffleWrite() |
long |
shuffleWriteRecords() |
int |
succeededTasks() |
long |
taskTime() |
public long diskBytesSpilled()
public int failedTasks()
public long inputBytes()
public long inputRecords()
public boolean isBlacklistedForStage()
public boolean isExcludedForStage()
public int killedTasks()
public long memoryBytesSpilled()
public long outputBytes()
public long outputRecords()
public scala.Option<org.apache.spark.executor.ExecutorMetrics> peakMemoryMetrics()
public long shuffleRead()
public long shuffleReadRecords()
public long shuffleWrite()
public long shuffleWriteRecords()
public int succeededTasks()
public long taskTime()