public class ReduceTaskAttemptImpl extends TaskAttemptImpl
conf, container, dataLocalHosts, dataLocalRacks, eventHandler, jobFile, partition
Constructor and Description |
---|
ReduceTaskAttemptImpl(TaskId id,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
int numMapTasks,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
Modifier and Type | Method and Description |
---|---|
Task |
createRemoteTask() |
getAssignedContainerID, getAssignedContainerMgrAddress, getAvataar, getCounters, getDiagnostics, getFinishTime, getID, getInternalState, getLaunchTime, getLocality, getNodeHttpAddress, getNodeId, getNodeRackName, getPhase, getProgress, getReport, getShuffleFinishTime, getShufflePort, getSortFinishTime, getState, handle, isFinished, isIP, recover, resolveHost, resolveHosts, setAvataar, setLocality
public ReduceTaskAttemptImpl(TaskId id, int attempt, EventHandler eventHandler, Path jobFile, int partition, int numMapTasks, JobConf conf, TaskAttemptListener taskAttemptListener, Token<JobTokenIdentifier> jobToken, Credentials credentials, Clock clock, AppContext appContext)
public Task createRemoteTask()
createRemoteTask
in class TaskAttemptImpl
Copyright © 2013 Apache Software Foundation. All rights reserved.