Packages

class TaskInfo extends AnyRef

:: DeveloperApi :: Information about a running task attempt inside a TaskSet.

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

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. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. 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.

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. val attemptNumber: Int
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @IntrinsicCandidate()
  8. def duration: Long
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  11. val executorId: String
  12. var failed: Boolean
  13. var finishTime: Long

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

  14. def finished: Boolean
  15. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  16. def gettingResult: Boolean
  17. 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).

  18. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  19. val host: String
  20. def id: String
  21. val index: Int
  22. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  23. var killed: Boolean
  24. val launchTime: Long
  25. var launching: Boolean
  26. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  27. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  28. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  29. val partitionId: Int
  30. def running: Boolean
  31. val speculative: Boolean
  32. def status: String
  33. def successful: Boolean
  34. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  35. val taskId: Long
  36. val taskLocality: TaskLocality.TaskLocality
  37. def toString(): String
    Definition Classes
    AnyRef → Any
  38. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  39. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  40. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped