Package org.apache.hadoop.mapred

Class ReduceTaskAttemptImpl

java.lang.Object

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

org.apache.hadoop.mapred.ReduceTaskAttemptImpl

All Implemented Interfaces:

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

public class ReduceTaskAttemptImpl
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

ReduceTaskAttemptImpl(org.apache.hadoop.mapreduce.v2.api.records.TaskId id, int attempt, org.apache.hadoop.yarn.event.EventHandler eventHandler, org.apache.hadoop.fs.Path jobFile, int partition, int numMapTasks, 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

ReduceTaskAttemptImpl

public ReduceTaskAttemptImpl(org.apache.hadoop.mapreduce.v2.api.records.TaskId id,
 int attempt,
 org.apache.hadoop.yarn.event.EventHandler eventHandler,
 org.apache.hadoop.fs.Path jobFile,
 int partition,
 int numMapTasks,
 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