Package org.apache.spark.status

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.Seq<Object> stageIds, scala.Option<String> jobGroup, scala.collection.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.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)