TaskInfo

Instance Constructors

new TaskInfo(taskId: Long, index: Int, attemptNumber: 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
val accumulables: ListBuffer[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[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
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[java.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
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
val host: String
def id: String
val index: Int
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
val launchTime: Long
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
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( ... )

Related Doc: package scheduler

class TaskInfo extends AnyRef

Instance Constructors

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

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

val accumulables: ListBuffer[AccumulableInfo]

final def asInstanceOf[T0]: T0

val attemptNumber: Int

def clone(): AnyRef

def duration: Long

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

val executorId: String

var failed: Boolean

def finalize(): Unit

var finishTime: Long

def finished: Boolean

final def getClass(): Class[_]

def gettingResult: Boolean

var gettingResultTime: Long

def hashCode(): Int

val host: String

def id: String

val index: Int

final def isInstanceOf[T0]: Boolean

val launchTime: Long

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def running: Boolean

val speculative: Boolean

def status: String

def successful: Boolean

final def synchronized[T0](arg0: ⇒ T0): T0

val taskId: Long

val taskLocality: TaskLocality.TaskLocality

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from AnyRef

Inherited from Any

Ungrouped