public class ExecutorSummary
extends Object
Modifier and Type | Method and Description |
---|---|
int |
activeTasks() |
java.util.Date |
addTime() |
int |
completedTasks() |
long |
diskUsed() |
scala.collection.immutable.Map<String,String> |
executorLogs() |
int |
failedTasks() |
String |
hostPort() |
String |
id() |
boolean |
isActive() |
boolean |
isBlacklisted() |
long |
maxMemory() |
int |
maxTasks() |
scala.Option<MemoryMetrics> |
memoryMetrics() |
long |
memoryUsed() |
int |
rddBlocks() |
scala.Option<String> |
removeReason() |
scala.Option<java.util.Date> |
removeTime() |
int |
totalCores() |
long |
totalDuration() |
long |
totalGCTime() |
long |
totalInputBytes() |
long |
totalShuffleRead() |
long |
totalShuffleWrite() |
int |
totalTasks() |
public String id()
public String hostPort()
public boolean isActive()
public int rddBlocks()
public long memoryUsed()
public long diskUsed()
public int totalCores()
public int maxTasks()
public int activeTasks()
public int failedTasks()
public int completedTasks()
public int totalTasks()
public long totalDuration()
public long totalGCTime()
public long totalInputBytes()
public long totalShuffleRead()
public long totalShuffleWrite()
public boolean isBlacklisted()
public long maxMemory()
public java.util.Date addTime()
public scala.Option<java.util.Date> removeTime()
public scala.Option<String> removeReason()
public scala.collection.immutable.Map<String,String> executorLogs()
public scala.Option<MemoryMetrics> memoryMetrics()