Package org.apache.hadoop.mapred

Class MapTaskAttemptImpl

java.lang.Object

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

org.apache.hadoop.mapred.MapTaskAttemptImpl

All Implemented Interfaces:

TaskAttempt, org.apache.hadoop.yarn.event.EventHandler<TaskAttemptEvent>

public class MapTaskAttemptImpl
extends TaskAttemptImpl

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl

conf, container, dataLocalHosts, dataLocalRacks, eventHandler, jobFile, partition, RESOURCE_REQUEST_CACHE

Constructor Summary

Constructors

Constructor

Description

MapTaskAttemptImpl(org.apache.hadoop.mapreduce.v2.api.records.TaskId taskId, int attempt, org.apache.hadoop.yarn.event.EventHandler eventHandler, org.apache.hadoop.fs.Path jobFile, int partition, org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo splitInfo, org.apache.hadoop.mapred.JobConf conf, TaskAttemptListener taskAttemptListener, org.apache.hadoop.security.token.Token<org.apache.hadoop.mapreduce.security.token.JobTokenIdentifier> jobToken, org.apache.hadoop.security.Credentials credentials, org.apache.hadoop.yarn.util.Clock clock, AppContext appContext)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.mapred.Task	createRemoteTask()

Methods inherited from class org.apache.hadoop.mapreduce.v2.app.job.impl.TaskAttemptImpl

getAssignedContainerID, getAssignedContainerMgrAddress, getAvataar, getCounters, getDiagnostics, getExternalState, getFinishTime, getID, getInternalState, getLaunchTime, getLocality, getNodeHttpAddress, getNodeId, getNodeRackName, getPhase, getProgress, getReport, getShuffleFinishTime, getShufflePort, getSortFinishTime, getState, handle, isFinished, isIP, isTaskFailFast, recover, resolveHost, resolveHosts, setAvataar, setLocality, setTaskFailFast

Methods inherited from class java.lang.Object

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

Constructor Details

MapTaskAttemptImpl

public MapTaskAttemptImpl(org.apache.hadoop.mapreduce.v2.api.records.TaskId taskId,
 int attempt,
 org.apache.hadoop.yarn.event.EventHandler eventHandler,
 org.apache.hadoop.fs.Path jobFile,
 int partition,
 org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo splitInfo,
 org.apache.hadoop.mapred.JobConf conf,
 TaskAttemptListener taskAttemptListener,
 org.apache.hadoop.security.token.Token<org.apache.hadoop.mapreduce.security.token.JobTokenIdentifier> jobToken,
 org.apache.hadoop.security.Credentials credentials,
 org.apache.hadoop.yarn.util.Clock clock,
 AppContext appContext)

Method Details

createRemoteTask

public org.apache.hadoop.mapred.Task createRemoteTask()

Specified by:

createRemoteTask in class TaskAttemptImpl