LiveExecutor (Spark 2.3.0 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()`
`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()`
`int`	`rddBlocks()`
`String`	`removeReason()`
`java.util.Date`	`removeTime()`
`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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

totalGcTime
```
public long totalGcTime()
```

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

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

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

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

executorLogs

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

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

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

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

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

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

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

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

executorId

hostPort

host

isActive

totalCores

addTime

removeTime

removeReason

rddBlocks

memoryUsed

diskUsed

maxTasks

maxMemory

totalTasks

activeTasks

completedTasks

failedTasks

totalDuration

totalGcTime

totalInputBytes

totalShuffleRead

totalShuffleWrite

isBlacklisted

executorLogs

totalOnHeap

totalOffHeap

usedOnHeap

usedOffHeap

hasMemoryInfo

hostname

lastWriteTime

write