org.apache.hadoop.mapreduce.v2.hs

Class CompletedTaskAttempt

java.lang.Object

org.apache.hadoop.mapreduce.v2.hs.CompletedTaskAttempt

All Implemented Interfaces:

TaskAttempt

public class CompletedTaskAttempt
extends Object
implements TaskAttempt

Method Summary

Methods

Modifier and Type	Method and Description
ContainerId	getAssignedContainerID()
String	getAssignedContainerMgrAddress()
Counters	getCounters()
List<String>	getDiagnostics()
long	getFinishTime()
TaskAttemptId	getID()
long	getLaunchTime()
String	getNodeHttpAddress()
NodeId	getNodeId()
String	getNodeRackName()
Phase	getPhase()
float	getProgress()
TaskAttemptReport	getReport()
long	getShuffleFinishTime()
int	getShufflePort()
long	getSortFinishTime()
TaskAttemptState	getState()
boolean	isFinished() Has attempt 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

getNodeId

public NodeId getNodeId()
                 throws UnsupportedOperationException

Specified by:

getNodeId in interface TaskAttempt

Returns:

node's id if a container is assigned, otherwise null.

Throws:

UnsupportedOperationException

getAssignedContainerID

public ContainerId getAssignedContainerID()

Specified by:

getAssignedContainerID in interface TaskAttempt

Returns:

the container ID if a container is assigned, otherwise null.

getAssignedContainerMgrAddress

public String getAssignedContainerMgrAddress()

Specified by:

getAssignedContainerMgrAddress in interface TaskAttempt

Returns:

container mgr address if a container is assigned, otherwise null.

getNodeHttpAddress

public String getNodeHttpAddress()

Specified by:

getNodeHttpAddress in interface TaskAttempt

Returns:

node's http address if a container is assigned, otherwise null.

getNodeRackName

public String getNodeRackName()

Specified by:

getNodeRackName in interface TaskAttempt

Returns:

node's rack name if a container is assigned, otherwise null.

getCounters

public Counters getCounters()

Specified by:

getCounters in interface TaskAttempt

getID

public TaskAttemptId getID()

Specified by:

getID in interface TaskAttempt

getProgress

public float getProgress()

Specified by:

getProgress in interface TaskAttempt

getReport

public TaskAttemptReport getReport()

Specified by:

getReport in interface TaskAttempt

getPhase

public Phase getPhase()

Specified by:

getPhase in interface TaskAttempt

getState

public TaskAttemptState getState()

Specified by:

getState in interface TaskAttempt

isFinished

public boolean isFinished()

Description copied from interface: TaskAttempt

Has attempt reached the final state or not.

Specified by:

isFinished in interface TaskAttempt

Returns:

true if it has finished, else false

getDiagnostics

public List<String> getDiagnostics()

Specified by:

getDiagnostics in interface TaskAttempt

getLaunchTime

public long getLaunchTime()

Specified by:

getLaunchTime in interface TaskAttempt

Returns:

time at which container is launched. If container is not launched yet, returns 0.

getFinishTime

public long getFinishTime()

Specified by:

getFinishTime in interface TaskAttempt

Returns:

attempt's finish time. If attempt is not finished yet, returns 0.

getShuffleFinishTime

public long getShuffleFinishTime()

Specified by:

getShuffleFinishTime in interface TaskAttempt

Returns:

The attempt's shuffle finish time if the attempt is a reduce. If attempt is not finished yet, returns 0.

getSortFinishTime

public long getSortFinishTime()

Specified by:

getSortFinishTime in interface TaskAttempt

Returns:

The attempt's sort or merge finish time if the attempt is a reduce. If attempt is not finished yet, returns 0.

getShufflePort

public int getShufflePort()

Specified by:

getShufflePort in interface TaskAttempt

Returns:

the port shuffle is on.