public class MapTaskImpl extends TaskImpl
appContext, clock, conf, credentials, encryptedShuffle, eventHandler, jobFile, jobToken, nextAttemptNumber, partition, taskAttemptListener
Constructor and Description |
---|
MapTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
JobSplit.TaskSplitMetaInfo taskSplitMetaInfo,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
Modifier and Type | Method and Description |
---|---|
protected TaskAttemptImpl |
createAttempt() |
protected int |
getMaxAttempts() |
protected String |
getSplitsAsString() |
protected JobSplit.TaskSplitMetaInfo |
getTaskSplitMetaInfo() |
TaskType |
getType() |
canCommit, getAttempt, getAttempts, getCounters, getID, getInternalState, getProgress, getReport, getState, getSuccessfulAttempt, handle, internalError, isFinished
public MapTaskImpl(JobId jobId, int partition, EventHandler eventHandler, Path remoteJobConfFile, JobConf conf, JobSplit.TaskSplitMetaInfo taskSplitMetaInfo, TaskAttemptListener taskAttemptListener, Token<JobTokenIdentifier> jobToken, Credentials credentials, Clock clock, int appAttemptId, MRAppMetrics metrics, AppContext appContext)
protected int getMaxAttempts()
getMaxAttempts
in class TaskImpl
protected TaskAttemptImpl createAttempt()
createAttempt
in class TaskImpl
public TaskType getType()
protected JobSplit.TaskSplitMetaInfo getTaskSplitMetaInfo()
protected String getSplitsAsString()
getSplitsAsString
in class TaskImpl
Copyright © 2013 Apache Software Foundation. All rights reserved.