|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use TaskUmbilicalProtocol | |
---|---|
org.apache.hadoop.mapred |
Uses of TaskUmbilicalProtocol in org.apache.hadoop.mapred |
---|
Fields in org.apache.hadoop.mapred declared as TaskUmbilicalProtocol | |
---|---|
protected TaskUmbilicalProtocol |
Task.umbilical
|
Methods in org.apache.hadoop.mapred that return TaskUmbilicalProtocol | |
---|---|
TaskUmbilicalProtocol |
ShuffleConsumerPlugin.Context.getUmbilical()
|
Methods in org.apache.hadoop.mapred with parameters of type TaskUmbilicalProtocol | |
---|---|
void |
Task.done(TaskUmbilicalProtocol umbilical,
Task.TaskReporter reporter)
|
protected void |
Task.reportNextRecordRange(TaskUmbilicalProtocol umbilical,
long nextRecIndex)
Reports the next executing record range to TaskTracker. |
void |
MapTask.run(JobConf job,
TaskUmbilicalProtocol umbilical)
|
abstract void |
Task.run(JobConf job,
TaskUmbilicalProtocol umbilical)
Run this task as a part of the named job. |
void |
ReduceTask.run(JobConf job,
TaskUmbilicalProtocol umbilical)
|
protected void |
Task.runJobCleanupTask(TaskUmbilicalProtocol umbilical,
Task.TaskReporter reporter)
|
protected void |
Task.runJobSetupTask(TaskUmbilicalProtocol umbilical,
Task.TaskReporter reporter)
|
protected void |
Task.runTaskCleanupTask(TaskUmbilicalProtocol umbilical,
Task.TaskReporter reporter)
|
void |
Task.statusUpdate(TaskUmbilicalProtocol umbilical)
Send a status update to the task tracker |
Constructors in org.apache.hadoop.mapred with parameters of type TaskUmbilicalProtocol | |
---|---|
ShuffleConsumerPlugin.Context(TaskAttemptID reduceId,
JobConf jobConf,
org.apache.hadoop.fs.FileSystem localFS,
TaskUmbilicalProtocol umbilical,
org.apache.hadoop.fs.LocalDirAllocator localDirAllocator,
Reporter reporter,
org.apache.hadoop.io.compress.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,
org.apache.hadoop.util.Progress copyPhase,
org.apache.hadoop.util.Progress mergePhase,
Task reduceTask,
MapOutputFile mapOutputFile)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |