public abstract class TaskAttemptImpl extends Object implements TaskAttempt, EventHandler<TaskAttemptEvent>
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 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) |
protected final JobConf conf
protected final Path jobFile
protected final int partition
protected EventHandler eventHandler
public Container container
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)
public ContainerId getAssignedContainerID()
getAssignedContainerID
in interface TaskAttempt
public String getAssignedContainerMgrAddress()
getAssignedContainerMgrAddress
in interface TaskAttempt
public long getLaunchTime()
getLaunchTime
in interface TaskAttempt
public long getFinishTime()
getFinishTime
in interface TaskAttempt
public long getShuffleFinishTime()
getShuffleFinishTime
in interface TaskAttempt
public long getSortFinishTime()
getSortFinishTime
in interface TaskAttempt
public int getShufflePort()
getShufflePort
in interface TaskAttempt
public NodeId getNodeId()
getNodeId
in interface TaskAttempt
public String getNodeHttpAddress()
getNodeHttpAddress
in interface TaskAttempt
public String getNodeRackName()
getNodeRackName
in interface TaskAttempt
protected abstract Task createRemoteTask()
public TaskAttemptId getID()
getID
in interface TaskAttempt
public boolean isFinished()
TaskAttempt
isFinished
in interface TaskAttempt
public TaskAttemptReport getReport()
getReport
in interface TaskAttempt
public List<String> getDiagnostics()
getDiagnostics
in interface TaskAttempt
public Counters getCounters()
getCounters
in interface TaskAttempt
public float getProgress()
getProgress
in interface TaskAttempt
public Phase getPhase()
getPhase
in interface TaskAttempt
public TaskAttemptState getState()
getState
in interface TaskAttempt
public void handle(TaskAttemptEvent event)
handle
in interface EventHandler<TaskAttemptEvent>
public TaskAttemptStateInternal getInternalState()
public Locality getLocality()
public void setLocality(Locality locality)
public Avataar getAvataar()
public void setAvataar(Avataar avataar)
public TaskAttemptStateInternal recover(JobHistoryParser.TaskAttemptInfo taInfo, OutputCommitter committer, boolean recoverOutput)
protected boolean isIP(String src)
Copyright © 2013 Apache Software Foundation. All rights reserved.