org.apache.hadoop.mapreduce.v2.app.job.impl

Class TaskAttemptImpl

java.lang.Object

org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl

All Implemented Interfaces:

TaskAttempt, EventHandler<TaskAttemptEvent>

Direct Known Subclasses:

MapTaskAttemptImpl, ReduceTaskAttemptImpl

public abstract class TaskAttemptImpl
extends Object
implements TaskAttempt, EventHandler<TaskAttemptEvent>

Implementation of TaskAttempt interface.

Field Summary

Fields

Modifier and Type	Field and Description
protected JobConf	conf
Container	container
protected Set<String>	dataLocalHosts
protected Set<String>	dataLocalRacks
protected EventHandler	eventHandler
protected Path	jobFile
protected int	partition

Constructor Summary

Constructors

Constructor and Description
TaskAttemptImpl(TaskId taskId, int i, EventHandler eventHandler, TaskAttemptListener taskAttemptListener, Path jobFile, int partition, JobConf conf, String[] dataLocalHosts, Token<JobTokenIdentifier> jobToken, Credentials credentials, Clock clock, AppContext appContext)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract Task	createRemoteTask()
ContainerId	getAssignedContainerID()
String	getAssignedContainerMgrAddress()
Avataar	getAvataar()
Counters	getCounters()
List<String>	getDiagnostics()
long	getFinishTime()
TaskAttemptId	getID()
TaskAttemptStateInternal	getInternalState()
long	getLaunchTime()
Locality	getLocality()
String	getNodeHttpAddress() If container Assigned then return the node's address, otherwise null.
NodeId	getNodeId()
String	getNodeRackName() If container Assigned then return the node's rackname, otherwise null.
Phase	getPhase()
float	getProgress()
TaskAttemptReport	getReport()
long	getShuffleFinishTime()
int	getShufflePort()
long	getSortFinishTime()
TaskAttemptState	getState()
void	handle(TaskAttemptEvent event)
boolean	isFinished() Has attempt reached the final state or not.
protected boolean	isIP(String src)
TaskAttemptStateInternal	recover(JobHistoryParser.TaskAttemptInfo taInfo, OutputCommitter committer, boolean recoverOutput)
protected String	resolveHost(String src)
protected Set<String>	resolveHosts(String[] src)
void	setAvataar(Avataar avataar)
void	setLocality(Locality locality)

Methods inherited from class java.lang.Object

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

Field Detail

conf

protected final JobConf conf

jobFile

protected final Path jobFile

partition

protected final int partition

eventHandler

protected EventHandler eventHandler

dataLocalHosts

protected Set<String> dataLocalHosts

dataLocalRacks

protected Set<String> dataLocalRacks

container

public Container container

Constructor Detail

TaskAttemptImpl

public TaskAttemptImpl(TaskId taskId,
               int i,
               EventHandler eventHandler,
               TaskAttemptListener taskAttemptListener,
               Path jobFile,
               int partition,
               JobConf conf,
               String[] dataLocalHosts,
               Token<JobTokenIdentifier> jobToken,
               Credentials credentials,
               Clock clock,
               AppContext appContext)

Method Detail

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.

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.

getNodeId

public NodeId getNodeId()

Specified by:

getNodeId in interface TaskAttempt

Returns:

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

getNodeHttpAddress

public String getNodeHttpAddress()

If container Assigned then return the node's address, otherwise null.

Specified by:

getNodeHttpAddress in interface TaskAttempt

Returns:

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

getNodeRackName

public String getNodeRackName()

If container Assigned then return the node's rackname, otherwise null.

Specified by:

getNodeRackName in interface TaskAttempt

Returns:

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

createRemoteTask

protected abstract Task createRemoteTask()

getID

public TaskAttemptId getID()

Specified by:

getID 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

getReport

public TaskAttemptReport getReport()

Specified by:

getReport in interface TaskAttempt

getDiagnostics

public List<String> getDiagnostics()

Specified by:

getDiagnostics in interface TaskAttempt

getCounters

public Counters getCounters()

Specified by:

getCounters in interface TaskAttempt

getProgress

public float getProgress()

Specified by:

getProgress in interface TaskAttempt

getPhase

public Phase getPhase()

Specified by:

getPhase in interface TaskAttempt

getState

public TaskAttemptState getState()

Specified by:

getState in interface TaskAttempt

handle

public void handle(TaskAttemptEvent event)

Specified by:

handle in interface EventHandler<TaskAttemptEvent>

getInternalState

public TaskAttemptStateInternal getInternalState()

getLocality

public Locality getLocality()

setLocality

public void setLocality(Locality locality)

getAvataar

public Avataar getAvataar()

setAvataar

public void setAvataar(Avataar avataar)

recover

public TaskAttemptStateInternal recover(JobHistoryParser.TaskAttemptInfo taInfo,
                               OutputCommitter committer,
                               boolean recoverOutput)

resolveHosts

protected Set<String> resolveHosts(String[] src)

resolveHost

protected String resolveHost(String src)

isIP

protected boolean isIP(String src)