public class ExecutorSummaryInfo
extends Object
implements scala.Product, scala.Serializable
Constructor and Description |
---|
ExecutorSummaryInfo(String id,
String hostPort,
int rddBlocks,
long memoryUsed,
long diskUsed,
int activeTasks,
int failedTasks,
int completedTasks,
int totalTasks,
long totalDuration,
long totalInputBytes,
long totalShuffleRead,
long totalShuffleWrite,
long maxMemory,
scala.collection.immutable.Map<String,String> executorLogs) |
Modifier and Type | Method and Description |
---|---|
int |
activeTasks() |
int |
completedTasks() |
long |
diskUsed() |
scala.collection.immutable.Map<String,String> |
executorLogs() |
int |
failedTasks() |
String |
hostPort() |
String |
id() |
long |
maxMemory() |
long |
memoryUsed() |
int |
rddBlocks() |
long |
totalDuration() |
long |
totalInputBytes() |
long |
totalShuffleRead() |
long |
totalShuffleWrite() |
int |
totalTasks() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ExecutorSummaryInfo(String id, String hostPort, int rddBlocks, long memoryUsed, long diskUsed, int activeTasks, int failedTasks, int completedTasks, int totalTasks, long totalDuration, long totalInputBytes, long totalShuffleRead, long totalShuffleWrite, long maxMemory, scala.collection.immutable.Map<String,String> executorLogs)
public String id()
public String hostPort()
public int rddBlocks()
public long memoryUsed()
public long diskUsed()
public int activeTasks()
public int failedTasks()
public int completedTasks()
public int totalTasks()
public long totalDuration()
public long totalInputBytes()
public long totalShuffleRead()
public long totalShuffleWrite()
public long maxMemory()
public scala.collection.immutable.Map<String,String> executorLogs()