Class LiveTask

Object
org.apache.spark.status.LiveTask

public class LiveTask extends Object
  • Constructor Details

    • LiveTask

      public LiveTask(TaskInfo info, int stageId, int stageAttemptId, scala.Option<Object> lastUpdateTime)
  • Method Details

    • errorMessage

      public scala.Option<String> errorMessage()
    • info

      public TaskInfo info()
    • updateMetrics

      public TaskMetrics updateMetrics(org.apache.spark.executor.TaskMetrics metrics)
      Update the metrics for the task and return the difference between the previous and new values.
      Parameters:
      metrics - (undocumented)
      Returns:
      (undocumented)
    • lastWriteTime

      public long lastWriteTime()
    • write

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