Package | Description |
---|---|
org.apache.hadoop.mapred | |
org.apache.hadoop.mapreduce.task.reduce |
Modifier and Type | Method and Description |
---|---|
TaskStatus |
ShuffleConsumerPlugin.Context.getStatus() |
Modifier and Type | Method and Description |
---|---|
void |
TaskAttemptListenerImpl.commitPending(TaskAttemptID taskAttemptID,
TaskStatus taskStatsu)
TaskAttempt is reporting that it is in commit_pending and it is waiting for
the commit Response
Commit it a two-phased protocol. |
void |
TaskUmbilicalProtocol.commitPending(TaskAttemptID taskId,
TaskStatus taskStatus)
Report that the task is complete, but its commit is pending.
|
boolean |
TaskAttemptListenerImpl.statusUpdate(TaskAttemptID taskAttemptID,
TaskStatus taskStatus) |
boolean |
TaskUmbilicalProtocol.statusUpdate(TaskAttemptID taskId,
TaskStatus taskStatus)
Report child's progress to parent.
|
Constructor and Description |
---|
ShuffleConsumerPlugin.Context(TaskAttemptID reduceId,
JobConf jobConf,
FileSystem localFS,
TaskUmbilicalProtocol umbilical,
LocalDirAllocator localDirAllocator,
Reporter reporter,
CompressionCodec codec,
Class<? extends Reducer> combinerClass,
Task.CombineOutputCollector<K,V> combineCollector,
Counters.Counter spilledRecordsCounter,
Counters.Counter reduceCombineInputCounter,
Counters.Counter shuffledMapsCounter,
Counters.Counter reduceShuffleBytes,
Counters.Counter failedShuffleCounter,
Counters.Counter mergedMapOutputsCounter,
TaskStatus status,
Progress copyPhase,
Progress mergePhase,
Task reduceTask,
MapOutputFile mapOutputFile) |
Constructor and Description |
---|
ShuffleSchedulerImpl(JobConf job,
TaskStatus status,
TaskAttemptID reduceId,
ExceptionReporter reporter,
Progress progress,
Counters.Counter shuffledMapsCounter,
Counters.Counter reduceShuffleBytes,
Counters.Counter failedShuffleCounter) |
Copyright © 2013 Apache Software Foundation. All rights reserved.