JobImpl(JobId jobId,
ApplicationAttemptId applicationAttemptId,
Configuration conf,
EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
JobTokenSecretManager jobTokenSecretManager,
Credentials jobCredentials,
Clock clock,
Map<TaskId,JobHistoryParser.TaskInfo> completedTasksFromPreviousRun,
MRAppMetrics metrics,
OutputCommitter committer,
boolean newApiCommitter,
String userName,
long appSubmitTime,
List<AMInfo> amInfos,
AppContext appContext,
JobStateInternal forcedState,
String forcedDiagnostic) |
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) |
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) |
TaskImpl(JobId jobId,
TaskType taskType,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |