Package | Description |
---|---|
org.apache.hadoop.mapred | |
org.apache.hadoop.mapreduce.split | |
org.apache.hadoop.mapreduce.v2.app.job.impl |
Constructor and Description |
---|
MapTaskAttemptImpl(TaskId taskId,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
JobSplit.TaskSplitMetaInfo splitInfo,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
Modifier and Type | Field and Description |
---|---|
static JobSplit.TaskSplitMetaInfo |
JobSplit.EMPTY_TASK_SPLIT |
Modifier and Type | Method and Description |
---|---|
static JobSplit.TaskSplitMetaInfo[] |
SplitMetaInfoReader.readSplitMetaInfo(JobID jobId,
FileSystem fs,
Configuration conf,
Path jobSubmitDir) |
Modifier and Type | Method and Description |
---|---|
protected JobSplit.TaskSplitMetaInfo[] |
JobImpl.InitTransition.createSplits(JobImpl job,
JobId jobId) |
protected JobSplit.TaskSplitMetaInfo |
MapTaskImpl.getTaskSplitMetaInfo() |
Constructor and Description |
---|
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) |
Copyright © 2013 Apache Software Foundation. All rights reserved.