appContext, clock, conf, credentials, encryptedShuffle, eventHandler, jobFile, jobToken, nextAttemptNumber, partition, taskAttemptListener
Constructor and Description |
---|
MapTaskImpl(org.apache.hadoop.mapreduce.v2.api.records.JobId jobId,
int partition,
org.apache.hadoop.yarn.event.EventHandler eventHandler,
org.apache.hadoop.fs.Path remoteJobConfFile,
org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo taskSplitMetaInfo,
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,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
Modifier and Type | Method and Description |
---|---|
protected TaskAttemptImpl |
createAttempt() |
protected int |
getMaxAttempts() |
protected String |
getSplitsAsString() |
protected org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo |
getTaskSplitMetaInfo() |
org.apache.hadoop.mapreduce.v2.api.records.TaskType |
getType() |
canCommit, getAttempt, getAttempts, getCounters, getID, getInternalState, getProgress, getReport, getState, getSuccessfulAttempt, handle, internalError, isFinished
public MapTaskImpl(org.apache.hadoop.mapreduce.v2.api.records.JobId jobId, int partition, org.apache.hadoop.yarn.event.EventHandler eventHandler, org.apache.hadoop.fs.Path remoteJobConfFile, org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo taskSplitMetaInfo, 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, int appAttemptId, MRAppMetrics metrics, AppContext appContext)
protected int getMaxAttempts()
getMaxAttempts
in class TaskImpl
protected TaskAttemptImpl createAttempt()
createAttempt
in class TaskImpl
public org.apache.hadoop.mapreduce.v2.api.records.TaskType getType()
protected org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo getTaskSplitMetaInfo()
protected String getSplitsAsString()
getSplitsAsString
in class TaskImpl
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.