org.apache.spark.scheduler

Class TaskInfo

Object

org.apache.spark.scheduler.TaskInfo

public class TaskInfo
extends Object

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

Constructor Summary

Constructors

Constructor and Description
TaskInfo(long taskId, int index, int attempt, long launchTime, String executorId, String host, scala.Enumeration.Value taskLocality, boolean speculative)

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.mutable.ListBuffer<AccumulableInfo>	accumulables() Intermediate updates to accumulables during this task.
int	attempt()
long	duration()
String	executorId()
boolean	failed()
boolean	finished()
long	finishTime() The time when the task has completed successfully (including the time to remotely fetch results, if necessary).
boolean	gettingResult()
long	gettingResultTime() The time when the task started remotely getting the result.
String	host()
String	id()
int	index()
long	launchTime()
void	markFailed(long time)
void	markGettingResult(long time)
void	markSuccessful(long time)
boolean	running()
boolean	speculative()
String	status()
boolean	successful()
long	taskId()
scala.Enumeration.Value	taskLocality()
long	timeRunning(long currentTime)

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskInfo

public TaskInfo(long taskId,
        int index,
        int attempt,
        long launchTime,
        String executorId,
        String host,
        scala.Enumeration.Value taskLocality,
        boolean speculative)

Method Detail

taskId

public long taskId()

index

public int index()

attempt

public int attempt()

launchTime

public long launchTime()

executorId

public String executorId()

host

public String host()

taskLocality

public scala.Enumeration.Value taskLocality()

speculative

public boolean speculative()

gettingResultTime

public long gettingResultTime()

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).

accumulables

public scala.collection.mutable.ListBuffer<AccumulableInfo> accumulables()

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.

finishTime

public long finishTime()

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

failed

public boolean failed()

markGettingResult

public void markGettingResult(long time)

markSuccessful

public void markSuccessful(long time)

markFailed

public void markFailed(long time)

gettingResult

public boolean gettingResult()

finished

public boolean finished()

successful

public boolean successful()

running

public boolean running()

status

public String status()

id

public String id()

duration

public long duration()

timeRunning

public long timeRunning(long currentTime)