Class LiveStage

Object
org.apache.spark.status.LiveStage

public class LiveStage extends Object
  • Constructor Details

    • LiveStage

      public LiveStage(StageInfo info)
  • Method Details

    • activeTasks

      public int activeTasks()
    • activeTasksPerExecutor

      public scala.collection.mutable.Map<String,Object> activeTasksPerExecutor()
    • cleaning

      public boolean cleaning()
    • completedIndices

      public org.apache.spark.util.collection.OpenHashSet<Object> completedIndices()
    • completedTasks

      public int completedTasks()
    • description

      public scala.Option<String> description()
    • excludedExecutors

      public scala.collection.immutable.HashSet<String> excludedExecutors()
    • executorSummaries

      public scala.collection.mutable.HashMap<String,LiveExecutorStageSummary> executorSummaries()
    • executorSummary

      public LiveExecutorStageSummary executorSummary(String executorId)
    • failedTasks

      public int failedTasks()
    • firstLaunchTime

      public long firstLaunchTime()
    • info

      public StageInfo info()
    • jobIds

      public scala.collection.immutable.Set<Object> jobIds()
    • jobs

      public scala.collection.Seq<LiveJob> jobs()
    • killedSummary

      public scala.collection.immutable.Map<String,Object> killedSummary()
    • killedTasks

      public int killedTasks()
    • localitySummary

      public scala.collection.immutable.Map<String,Object> localitySummary()
    • metrics

      public TaskMetrics metrics()
    • peakExecutorMetrics

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

      public AtomicInteger savedTasks()
    • schedulingPool

      public String schedulingPool()
    • speculationStageSummary

      public LiveSpeculationStageSummary speculationStageSummary()
    • status

      public StageStatus status()
    • toApi

      public StageData toApi()
    • lastWriteTime

      public long lastWriteTime()
    • write

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