Package org.apache.spark.status
Class LiveStage
Object
org.apache.spark.status.LiveStage
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionint
boolean
cleaning()
org.apache.spark.util.collection.OpenHashSet<Object>
int
scala.Option<String>
scala.collection.immutable.HashSet<String>
scala.collection.mutable.HashMap<String,
LiveExecutorStageSummary> executorSummary
(String executorId) int
long
info()
scala.collection.immutable.Set<Object>
jobIds()
scala.collection.Seq<LiveJob>
jobs()
int
long
metrics()
org.apache.spark.executor.ExecutorMetrics
status()
toApi()
void
write
(org.apache.spark.status.ElementTrackingStore store, long now, boolean checkTriggers)
-
Constructor Details
-
LiveStage
-
-
Method Details
-
activeTasks
public int activeTasks() -
activeTasksPerExecutor
-
cleaning
public boolean cleaning() -
completedIndices
-
completedTasks
public int completedTasks() -
description
-
excludedExecutors
-
executorSummaries
-
executorSummary
-
failedTasks
public int failedTasks() -
firstLaunchTime
public long firstLaunchTime() -
info
-
jobIds
-
jobs
-
killedSummary
-
killedTasks
public int killedTasks() -
localitySummary
-
metrics
-
peakExecutorMetrics
public org.apache.spark.executor.ExecutorMetrics peakExecutorMetrics() -
savedTasks
-
schedulingPool
-
speculationStageSummary
-
status
-
toApi
-
lastWriteTime
public long lastWriteTime() -
write
public void write(org.apache.spark.status.ElementTrackingStore store, long now, boolean checkTriggers)
-