public abstract class TaskImpl extends Object implements Task, org.apache.hadoop.yarn.event.EventHandler<TaskEvent>
Modifier and Type | Field and Description |
---|---|
protected AppContext |
appContext |
protected org.apache.hadoop.yarn.util.Clock |
clock |
protected org.apache.hadoop.mapred.JobConf |
conf |
protected org.apache.hadoop.security.Credentials |
credentials |
protected boolean |
encryptedShuffle |
protected org.apache.hadoop.yarn.event.EventHandler |
eventHandler |
protected org.apache.hadoop.fs.Path |
jobFile |
protected org.apache.hadoop.security.token.Token<org.apache.hadoop.mapreduce.security.token.JobTokenIdentifier> |
jobToken |
protected int |
nextAttemptNumber |
protected int |
partition |
protected TaskAttemptListener |
taskAttemptListener |
Constructor and Description |
---|
TaskImpl(org.apache.hadoop.mapreduce.v2.api.records.JobId jobId,
org.apache.hadoop.mapreduce.v2.api.records.TaskType taskType,
int partition,
org.apache.hadoop.yarn.event.EventHandler eventHandler,
org.apache.hadoop.fs.Path remoteJobConfFile,
org.apache.hadoop.mapred.JobConf conf,
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 |
---|---|
boolean |
canCommit(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId taskAttemptID)
Can the output of the taskAttempt be committed.
|
protected abstract TaskAttemptImpl |
createAttempt() |
TaskAttempt |
getAttempt(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId attemptID) |
Map<org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId,TaskAttempt> |
getAttempts() |
org.apache.hadoop.mapreduce.Counters |
getCounters() |
org.apache.hadoop.mapreduce.v2.api.records.TaskId |
getID() |
TaskStateInternal |
getInternalState() |
protected abstract int |
getMaxAttempts() |
float |
getProgress() |
org.apache.hadoop.mapreduce.v2.api.records.TaskReport |
getReport() |
protected String |
getSplitsAsString() |
org.apache.hadoop.mapreduce.v2.api.records.TaskState |
getState() |
protected TaskAttempt |
getSuccessfulAttempt() |
void |
handle(TaskEvent event) |
protected void |
internalError(TaskEventType type) |
boolean |
isFinished()
Has Task reached the final state or not.
|
protected final org.apache.hadoop.mapred.JobConf conf
protected final org.apache.hadoop.fs.Path jobFile
protected final int partition
protected final TaskAttemptListener taskAttemptListener
protected final org.apache.hadoop.yarn.event.EventHandler eventHandler
protected final org.apache.hadoop.yarn.util.Clock clock
protected final AppContext appContext
protected boolean encryptedShuffle
protected org.apache.hadoop.security.Credentials credentials
protected org.apache.hadoop.security.token.Token<org.apache.hadoop.mapreduce.security.token.JobTokenIdentifier> jobToken
protected int nextAttemptNumber
public TaskImpl(org.apache.hadoop.mapreduce.v2.api.records.JobId jobId, org.apache.hadoop.mapreduce.v2.api.records.TaskType taskType, int partition, org.apache.hadoop.yarn.event.EventHandler eventHandler, org.apache.hadoop.fs.Path remoteJobConfFile, org.apache.hadoop.mapred.JobConf conf, 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)
public org.apache.hadoop.mapreduce.v2.api.records.TaskState getState()
public Map<org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId,TaskAttempt> getAttempts()
getAttempts
in interface Task
public TaskAttempt getAttempt(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId attemptID)
getAttempt
in interface Task
public org.apache.hadoop.mapreduce.v2.api.records.TaskId getID()
public boolean isFinished()
Task
isFinished
in interface Task
public org.apache.hadoop.mapreduce.v2.api.records.TaskReport getReport()
public org.apache.hadoop.mapreduce.Counters getCounters()
getCounters
in interface Task
public float getProgress()
getProgress
in interface Task
@VisibleForTesting public TaskStateInternal getInternalState()
public boolean canCommit(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId taskAttemptID)
Task
protected abstract TaskAttemptImpl createAttempt()
protected abstract int getMaxAttempts()
protected TaskAttempt getSuccessfulAttempt()
public void handle(TaskEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<TaskEvent>
protected void internalError(TaskEventType type)
protected String getSplitsAsString()
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.