Class LiveJob

Object
org.apache.spark.status.LiveJob

public class LiveJob extends Object
  • Constructor Details

    • LiveJob

      public LiveJob(int jobId, String name, scala.Option<String> description, scala.Option<Date> submissionTime, scala.collection.immutable.Seq<Object> stageIds, scala.Option<String> jobGroup, scala.collection.immutable.Seq<String> jobTags, int numTasks, scala.Option<Object> sqlExecutionId)
  • Method Details

    • activeStages

      public int activeStages()
    • activeTasks

      public int activeTasks()
    • completedIndices

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

      public scala.collection.immutable.Set<Object> completedStages()
    • completedTasks

      public int completedTasks()
    • completionTime

      public scala.Option<Date> completionTime()
    • failedStages

      public int failedStages()
    • failedTasks

      public int failedTasks()
    • jobId

      public int jobId()
    • killedSummary

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

      public int killedTasks()
    • skippedStages

      public scala.collection.immutable.Set<Object> skippedStages()
    • skippedTasks

      public int skippedTasks()
    • stageIds

      public scala.collection.immutable.Seq<Object> stageIds()
    • status

      public JobExecutionStatus status()
    • submissionTime

      public scala.Option<Date> submissionTime()
    • lastWriteTime

      public long lastWriteTime()
    • write

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