public class MapTaskAttemptImpl extends TaskAttemptImpl
conf, container, dataLocalHosts, dataLocalRacks, eventHandler, jobFile, partition
Constructor and Description |
---|
MapTaskAttemptImpl(TaskId taskId,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
JobSplit.TaskSplitMetaInfo splitInfo,
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 MapTaskAttemptImpl(TaskId taskId, int attempt, EventHandler eventHandler, Path jobFile, int partition, JobSplit.TaskSplitMetaInfo splitInfo, 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.