JobImpl(org.apache.hadoop.mapreduce.v2.api.records.JobId jobId,
org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.yarn.event.EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
org.apache.hadoop.mapreduce.security.token.JobTokenSecretManager jobTokenSecretManager,
org.apache.hadoop.security.Credentials jobCredentials,
org.apache.hadoop.yarn.util.Clock clock,
Map<org.apache.hadoop.mapreduce.v2.api.records.TaskId,org.apache.hadoop.mapreduce.jobhistory.JobHistoryParser.TaskInfo> completedTasksFromPreviousRun,
MRAppMetrics metrics,
org.apache.hadoop.mapreduce.OutputCommitter committer,
boolean newApiCommitter,
String userName,
long appSubmitTime,
List<org.apache.hadoop.mapreduce.v2.api.records.AMInfo> amInfos,
AppContext appContext,
JobStateInternal forcedState,
String forcedDiagnostic) |
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) |
ReduceTaskImpl(org.apache.hadoop.mapreduce.v2.api.records.JobId jobId,
int partition,
org.apache.hadoop.yarn.event.EventHandler eventHandler,
org.apache.hadoop.fs.Path jobFile,
org.apache.hadoop.mapred.JobConf conf,
int numMapTasks,
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) |
TaskAttemptImpl(org.apache.hadoop.mapreduce.v2.api.records.TaskId taskId,
int i,
org.apache.hadoop.yarn.event.EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
org.apache.hadoop.fs.Path jobFile,
int partition,
org.apache.hadoop.mapred.JobConf conf,
String[] dataLocalHosts,
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,
AppContext appContext) |
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) |