class TaskInfo extends Cloneable
:: DeveloperApi :: Information about a running task attempt inside a TaskSet.
- Annotations
- @DeveloperApi()
- Source
- TaskInfo.scala
- Alphabetic
- By Inheritance
- TaskInfo
- Cloneable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- 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.
- new TaskInfo(taskId: Long, index: Int, attemptNumber: Int, partitionId: Int, launchTime: Long, executorId: String, host: String, taskLocality: TaskLocality.TaskLocality, speculative: Boolean)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- 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.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val attemptNumber: Int
- def clone(): TaskInfo
- Definition Classes
- TaskInfo → AnyRef
- def duration: Long
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- val executorId: String
- var failed: Boolean
- var finishTime: Long
The time when the task has completed successfully (including the time to remotely fetch results, if necessary).
- def finished: Boolean
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def gettingResult: Boolean
- 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).
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- val host: String
- def id: String
- val index: Int
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- var killed: Boolean
- val launchTime: Long
- var launching: Boolean
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- val partitionId: Int
- def running: Boolean
- val speculative: Boolean
- def status: String
- def successful: Boolean
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val taskId: Long
- val taskLocality: TaskLocality.TaskLocality
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)