@InterfaceAudience.Private @InterfaceStability.Unstable public class ReduceTask extends Task
Modifier and Type | Class and Description |
---|---|
static class |
ReduceTask.ReduceCopier<K,V> |
Task.CombineOutputCollector<K,V>, Task.CombinerRunner<K,V>, Task.CombineValuesIterator<KEY,VALUE>, Task.Counter, Task.NewCombinerRunner<K,V>, Task.OldCombinerRunner<K,V>, Task.TaskReporter
committer, conf, DEFAULT_MR_COMBINE_RECORDS_BEFORE_PROGRESS, FILESYSTEM_COUNTER_GROUP, jobCleanup, jobContext, jobRunStateForCleanup, jobSetup, jvmContext, lDirAlloc, mapOutputFile, MR_COMBINE_RECORDS_BEFORE_PROGRESS, outputFormat, PROGRESS_INTERVAL, spilledRecordsCounter, taskCleanup, taskContext, tokenSecret, umbilical
Constructor and Description |
---|
ReduceTask() |
ReduceTask(java.lang.String jobFile,
TaskAttemptID taskId,
int partition,
int numMaps,
int numSlotsRequired) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.TaskRunner |
createRunner(TaskTracker tracker,
org.apache.hadoop.mapred.TaskTracker.TaskInProgress tip,
org.apache.hadoop.mapred.TaskTracker.RunningJob rjob)
Return an approprate thread runner for this task.
|
int |
getNumMaps() |
boolean |
isMapTask() |
void |
localizeConfiguration(JobConf conf)
Localize the given JobConf to be specific for this task.
|
void |
readFields(java.io.DataInput in) |
void |
run(JobConf job,
TaskUmbilicalProtocol umbilical)
Run this task as a part of the named job.
|
void |
write(java.io.DataOutput out) |
createReduceContext, done, getConf, getFileSystemCounterNames, getJobFile, getJobID, getJobTokenSecret, getJvmContext, getMapOutputFile, getNumSlotsRequired, getPartition, getPhase, getProgress, getSkipRanges, getTaskID, getUser, initialize, isSkipping, reportFatalError, reportNextRecordRange, runJobCleanupTask, runJobSetupTask, runTaskCleanupTask, setConf, setJobFile, setJobTokenSecret, setJvmContext, setPhase, setSkipping, setSkipRanges, setWriteSkipRecs, statusUpdate, supportIsolationRunner, toString, toWriteSkipRecs, writeFilesRequiredForRerun
public ReduceTask()
public ReduceTask(java.lang.String jobFile, TaskAttemptID taskId, int partition, int numMaps, int numSlotsRequired)
public org.apache.hadoop.mapred.TaskRunner createRunner(TaskTracker tracker, org.apache.hadoop.mapred.TaskTracker.TaskInProgress tip, org.apache.hadoop.mapred.TaskTracker.RunningJob rjob) throws java.io.IOException
Task
createRunner
in class Task
tip
- TODOjava.io.IOException
public int getNumMaps()
public void localizeConfiguration(JobConf conf) throws java.io.IOException
localizeConfiguration
in class Task
java.io.IOException
public void write(java.io.DataOutput out) throws java.io.IOException
public void readFields(java.io.DataInput in) throws java.io.IOException
readFields
in interface org.apache.hadoop.io.Writable
readFields
in class Task
java.io.IOException
public void run(JobConf job, TaskUmbilicalProtocol umbilical) throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
Task
Copyright © 2009 The Apache Software Foundation