public class LiveStage
extends Object
Modifier and Type | Method and Description |
---|---|
int |
activeTasks() |
scala.collection.mutable.Map<String,Object> |
activeTasksPerExecutor() |
boolean |
cleaning() |
org.apache.spark.util.collection.OpenHashSet<Object> |
completedIndices() |
int |
completedTasks() |
scala.Option<String> |
description() |
scala.collection.immutable.HashSet<String> |
excludedExecutors() |
scala.collection.mutable.HashMap<String,LiveExecutorStageSummary> |
executorSummaries() |
LiveExecutorStageSummary |
executorSummary(String executorId) |
int |
failedTasks() |
long |
firstLaunchTime() |
StageInfo |
info() |
scala.collection.immutable.Set<Object> |
jobIds() |
scala.collection.Seq<LiveJob> |
jobs() |
scala.collection.immutable.Map<String,Object> |
killedSummary() |
int |
killedTasks() |
long |
lastWriteTime() |
scala.collection.immutable.Map<String,Object> |
localitySummary() |
TaskMetrics |
metrics() |
org.apache.spark.executor.ExecutorMetrics |
peakExecutorMetrics() |
java.util.concurrent.atomic.AtomicInteger |
savedTasks() |
String |
schedulingPool() |
StageStatus |
status() |
StageData |
toApi() |
void |
write(org.apache.spark.status.ElementTrackingStore store,
long now,
boolean checkTriggers) |
public LiveStage(StageInfo info)
public int activeTasks()
public scala.collection.mutable.Map<String,Object> activeTasksPerExecutor()
public boolean cleaning()
public org.apache.spark.util.collection.OpenHashSet<Object> completedIndices()
public int completedTasks()
public scala.Option<String> description()
public scala.collection.immutable.HashSet<String> excludedExecutors()
public scala.collection.mutable.HashMap<String,LiveExecutorStageSummary> executorSummaries()
public LiveExecutorStageSummary executorSummary(String executorId)
public int failedTasks()
public long firstLaunchTime()
public StageInfo info()
public scala.collection.immutable.Set<Object> jobIds()
public scala.collection.Seq<LiveJob> jobs()
public scala.collection.immutable.Map<String,Object> killedSummary()
public int killedTasks()
public scala.collection.immutable.Map<String,Object> localitySummary()
public TaskMetrics metrics()
public org.apache.spark.executor.ExecutorMetrics peakExecutorMetrics()
public java.util.concurrent.atomic.AtomicInteger savedTasks()
public String schedulingPool()
public StageStatus status()
public StageData toApi()
public long lastWriteTime()
public void write(org.apache.spark.status.ElementTrackingStore store, long now, boolean checkTriggers)