org.apache.hadoop.mapreduce.v2.hs

Class CompletedTask

java.lang.Object

org.apache.hadoop.mapreduce.v2.hs.CompletedTask

All Implemented Interfaces:

Task

public class CompletedTask
extends Object
implements Task

Method Summary

Methods

Modifier and Type	Method and Description
boolean	canCommit(TaskAttemptId taskAttemptID) Can the output of the taskAttempt be committed.
TaskAttempt	getAttempt(TaskAttemptId attemptID)
Map<TaskAttemptId,TaskAttempt>	getAttempts()
Counters	getCounters()
TaskId	getID()
float	getProgress()
TaskReport	getReport()
TaskState	getState()
TaskType	getType()
boolean	isFinished() Has Task reached the final state or not.

Methods inherited from class java.lang.Object

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

Method Detail

canCommit

public boolean canCommit(TaskAttemptId taskAttemptID)

Description copied from interface: Task

Can the output of the taskAttempt be committed. Note that once the task gives a go for a commit, further canCommit requests from any other attempts should return false.

Specified by:

canCommit in interface Task

Returns:

whether the attempt's output can be committed or not.

getAttempt

public TaskAttempt getAttempt(TaskAttemptId attemptID)

Specified by:

getAttempt in interface Task

getAttempts

public Map<TaskAttemptId,TaskAttempt> getAttempts()

Specified by:

getAttempts in interface Task

getCounters

public Counters getCounters()

Specified by:

getCounters in interface Task

getID

public TaskId getID()

Specified by:

getID in interface Task

getProgress

public float getProgress()

Specified by:

getProgress in interface Task

getReport

public TaskReport getReport()

Specified by:

getReport in interface Task

getType

public TaskType getType()

Specified by:

getType in interface Task

isFinished

public boolean isFinished()

Description copied from interface: Task

Has Task reached the final state or not.

Specified by:

isFinished in interface Task

getState

public TaskState getState()

Specified by:

getState in interface Task