public class ReduceTaskImpl extends TaskImpl
appContext, clock, conf, credentials, encryptedShuffle, eventHandler, jobFile, jobToken, nextAttemptNumber, partition, taskAttemptListener
Constructor and Description |
---|
ReduceTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path jobFile,
JobConf conf,
int numMapTasks,
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() |
TaskType |
getType() |
canCommit, getAttempt, getAttempts, getCounters, getID, getInternalState, getProgress, getReport, getSplitsAsString, getState, getSuccessfulAttempt, handle, internalError, isFinished
public ReduceTaskImpl(JobId jobId, int partition, EventHandler eventHandler, Path jobFile, JobConf conf, int numMapTasks, 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()
Copyright © 2013 Apache Software Foundation. All rights reserved.