Packages

class TaskInfo extends Cloneable

Developer API

Information about a running task attempt inside a TaskSet.

Annotations
@DeveloperApi()
Source
TaskInfo.scala
Linear Supertypes
Cloneable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TaskInfo
  2. Cloneable
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new TaskInfo(taskId: Long, index: Int, attemptNumber: Int, launchTime: Long, executorId: String, host: String, taskLocality: TaskLocality.TaskLocality, speculative: Boolean)

    This api doesn't contains partitionId, please use the new api.

    This api doesn't contains partitionId, please use the new api. Remain it for backward compatibility before Spark 3.3.

  2. new TaskInfo(taskId: Long, index: Int, attemptNumber: Int, partitionId: Int, launchTime: Long, executorId: String, host: String, taskLocality: TaskLocality.TaskLocality, speculative: Boolean)

Value Members

  1. def accumulables: Seq[AccumulableInfo]

    Intermediate updates to accumulables during this task.

    Intermediate updates to accumulables during this task. Note that it is valid for the same accumulable to be updated multiple times in a single task or for two accumulables with the same name but different IDs to exist in a task.

  2. val attemptNumber: Int
  3. def clone(): TaskInfo
    Definition Classes
    TaskInfo → AnyRef
  4. def duration: Long
  5. val executorId: String
  6. var failed: Boolean
  7. var finishTime: Long

    The time when the task has completed successfully (including the time to remotely fetch results, if necessary).

  8. def finished: Boolean
  9. def gettingResult: Boolean
  10. var gettingResultTime: Long

    The time when the task started remotely getting the result.

    The time when the task started remotely getting the result. Will not be set if the task result was sent immediately when the task finished (as opposed to sending an IndirectTaskResult and later fetching the result from the block manager).

  11. val host: String
  12. def id: String
  13. val index: Int
  14. var killed: Boolean
  15. val launchTime: Long
  16. var launching: Boolean
  17. val partitionId: Int
  18. def running: Boolean
  19. val speculative: Boolean
  20. def status: String
  21. def successful: Boolean
  22. val taskId: Long
  23. val taskLocality: TaskLocality.TaskLocality