class TaskInfo extends AnyRef
:: DeveloperApi :: Information about a running task attempt inside a TaskSet.
- Annotations
- @DeveloperApi()
- Source
- TaskInfo.scala
- Alphabetic
- By Inheritance
- TaskInfo
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def duration: Long
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val executorId: String
- var failed: Boolean
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
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[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @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
- @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
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @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(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()