ExecutorSummary (Spark 3.5.0 JavaDoc)

Object
- org.apache.spark.status.api.v1.ExecutorSummary

public class ExecutorSummary
extends Object

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`int`	`activeTasks()`
`java.util.Date`	`addTime()`
`scala.collection.immutable.Map<String,String>`	`attributes()`
`scala.collection.immutable.Set<Object>`	`blacklistedInStages()` Deprecated. use excludedInStages instead. Since 3.1.0.
`int`	`completedTasks()`
`long`	`diskUsed()`
`scala.collection.immutable.Set<Object>`	`excludedInStages()`
`scala.collection.immutable.Map<String,String>`	`executorLogs()`
`int`	`failedTasks()`
`String`	`hostPort()`
`String`	`id()`
`boolean`	`isActive()`
`boolean`	`isBlacklisted()` Deprecated. use isExcluded instead. Since 3.1.0.
`boolean`	`isExcluded()`
`long`	`maxMemory()`
`int`	`maxTasks()`
`scala.Option<MemoryMetrics>`	`memoryMetrics()`
`long`	`memoryUsed()`
`scala.Option<org.apache.spark.executor.ExecutorMetrics>`	`peakMemoryMetrics()`
`int`	`rddBlocks()`
`scala.Option<String>`	`removeReason()`
`scala.Option<java.util.Date>`	`removeTime()`
`int`	`resourceProfileId()`
`scala.collection.immutable.Map<String,ResourceInformation>`	`resources()`
`int`	`totalCores()`
`long`	`totalDuration()`
`long`	`totalGCTime()`
`long`	`totalInputBytes()`
`long`	`totalShuffleRead()`
`long`	`totalShuffleWrite()`
`int`	`totalTasks()`

Methods inherited from class Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

activeTasks
```
public int activeTasks()
```

addTime
```
public java.util.Date addTime()
```

attributes

public scala.collection.immutable.Map<String,String> attributes()

blacklistedInStages
```
public scala.collection.immutable.Set<Object> blacklistedInStages()
```
Deprecated. use excludedInStages instead. Since 3.1.0.

completedTasks
```
public int completedTasks()
```

diskUsed
```
public long diskUsed()
```

excludedInStages

public scala.collection.immutable.Set<Object> excludedInStages()

executorLogs

public scala.collection.immutable.Map<String,String> executorLogs()

failedTasks
```
public int failedTasks()
```

hostPort
```
public String hostPort()
```

id
```
public String id()
```

isActive
```
public boolean isActive()
```

isBlacklisted
```
public boolean isBlacklisted()
```
Deprecated. use isExcluded instead. Since 3.1.0.

isExcluded
```
public boolean isExcluded()
```

maxMemory
```
public long maxMemory()
```

maxTasks
```
public int maxTasks()
```

memoryMetrics

public scala.Option<MemoryMetrics> memoryMetrics()

memoryUsed
```
public long memoryUsed()
```

peakMemoryMetrics

public scala.Option<org.apache.spark.executor.ExecutorMetrics> peakMemoryMetrics()

rddBlocks
```
public int rddBlocks()
```

removeReason

public scala.Option<String> removeReason()

removeTime

public scala.Option<java.util.Date> removeTime()

resourceProfileId
```
public int resourceProfileId()
```

resources

public scala.collection.immutable.Map<String,ResourceInformation> resources()

totalCores
```
public int totalCores()
```

totalDuration
```
public long totalDuration()
```

totalGCTime
```
public long totalGCTime()
```

totalInputBytes
```
public long totalInputBytes()
```

totalShuffleRead
```
public long totalShuffleRead()
```

totalShuffleWrite
```
public long totalShuffleWrite()
```

totalTasks
```
public int totalTasks()
```

Class ExecutorSummary

Method Summary

Methods inherited from class Object

Method Detail

activeTasks

addTime

attributes

blacklistedInStages

completedTasks

diskUsed

excludedInStages

executorLogs

failedTasks

hostPort

id

isActive

isBlacklisted

isExcluded

maxMemory

maxTasks

memoryMetrics

memoryUsed

peakMemoryMetrics

rddBlocks

removeReason

removeTime

resourceProfileId

resources

totalCores

totalDuration

totalGCTime

totalInputBytes

totalShuffleRead

totalShuffleWrite

totalTasks