LiveExecutor (Spark 3.0.0-preview2 JavaDoc)

Object
- org.apache.spark.status.LiveExecutor

public class LiveExecutor
extends Object

Constructor Summary

Constructors
Constructor and Description

LiveExecutor(String executorId, long _addTime)

Constructors
Constructor and Description
`LiveExecutor(String executorId, long _addTime)`

Method Summary

All Methods Instance Methods Concrete 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()`
`int`	`completedTasks()`
`long`	`diskUsed()`
`String`	`executorId()`
`scala.collection.immutable.Map<String,String>`	`executorLogs()`
`int`	`failedTasks()`
`boolean`	`hasMemoryInfo()`
`String`	`host()`
`String`	`hostname()`
`String`	`hostPort()`
`boolean`	`isActive()`
`boolean`	`isBlacklisted()`
`long`	`lastWriteTime()`
`long`	`maxMemory()`
`int`	`maxTasks()`
`long`	`memoryUsed()`
`org.apache.spark.executor.ExecutorMetrics`	`peakExecutorMetrics()`
`int`	`rddBlocks()`
`String`	`removeReason()`
`java.util.Date`	`removeTime()`
`scala.collection.immutable.Map<String,ResourceInformation>`	`resources()`
`int`	`totalCores()`
`long`	`totalDuration()`
`long`	`totalGcTime()`
`long`	`totalInputBytes()`
`long`	`totalOffHeap()`
`long`	`totalOnHeap()`
`long`	`totalShuffleRead()`
`long`	`totalShuffleWrite()`
`int`	`totalTasks()`
`long`	`usedOffHeap()`
`long`	`usedOnHeap()`
`void`	`write(org.apache.spark.status.ElementTrackingStore store, long now, boolean checkTriggers)`

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

Constructor Detail

LiveExecutor

public LiveExecutor(String executorId,
                    long _addTime)

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()

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

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

executorId
```
public String executorId()
```

executorLogs

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

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

hasMemoryInfo
```
public boolean hasMemoryInfo()
```

host
```
public String host()
```

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

hostname
```
public String hostname()
```

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

isBlacklisted
```
public boolean isBlacklisted()
```

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

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

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

peakExecutorMetrics

public org.apache.spark.executor.ExecutorMetrics peakExecutorMetrics()

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

removeReason
```
public String removeReason()
```

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

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()
```

totalOffHeap
```
public long totalOffHeap()
```

totalOnHeap
```
public long totalOnHeap()
```

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

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

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

usedOffHeap
```
public long usedOffHeap()
```

usedOnHeap
```
public long usedOnHeap()
```

lastWriteTime
```
public long lastWriteTime()
```

write

public void write(org.apache.spark.status.ElementTrackingStore store,
                  long now,
                  boolean checkTriggers)

Class LiveExecutor

Constructor Summary

Method Summary

Methods inherited from class Object

Constructor Detail

LiveExecutor

Method Detail

activeTasks

addTime

attributes

blacklistedInStages

completedTasks

diskUsed

executorId

executorLogs

failedTasks

hasMemoryInfo

host

hostPort

hostname

isActive

isBlacklisted

maxMemory

maxTasks

memoryUsed

peakExecutorMetrics

rddBlocks

removeReason

removeTime

resources

totalCores

totalDuration

totalGcTime

totalInputBytes

totalOffHeap

totalOnHeap

totalShuffleRead

totalShuffleWrite

totalTasks

usedOffHeap

usedOnHeap

lastWriteTime

write