Package | Description |
---|---|
org.apache.hadoop.mapred | |
org.apache.hadoop.mapreduce.v2.app | |
org.apache.hadoop.mapreduce.v2.app.job.impl | |
org.apache.hadoop.mapreduce.v2.app.launcher |
Modifier and Type | Class and Description |
---|---|
class |
MapTask
A Map task.
|
class |
ReduceTask
A Reduce task.
|
Modifier and Type | Method and Description |
---|---|
Task |
MapTaskAttemptImpl.createRemoteTask() |
Task |
ReduceTaskAttemptImpl.createRemoteTask() |
Task |
ShuffleConsumerPlugin.Context.getReduceTask() |
Task |
JvmTask.getTask() |
Modifier and Type | Method and Description |
---|---|
static List<String> |
MapReduceChildJVM.getVMCommand(InetSocketAddress taskAttemptListenerAddr,
Task task,
ID jvmID) |
void |
TaskAttemptListenerImpl.registerPendingTask(Task task,
WrappedJvmID jvmID) |
static void |
MapReduceChildJVM.setVMEnv(Map<String,String> environment,
Task task) |
Constructor and Description |
---|
JvmTask(Task t,
boolean shouldDie) |
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) |
Modifier and Type | Method and Description |
---|---|
void |
TaskAttemptListener.registerPendingTask(Task task,
WrappedJvmID jvmID)
Register a JVM with the listener.
|
Modifier and Type | Method and Description |
---|---|
protected abstract Task |
TaskAttemptImpl.createRemoteTask() |
Modifier and Type | Method and Description |
---|---|
Task |
ContainerRemoteLaunchEvent.getRemoteTask() |
Constructor and Description |
---|
ContainerRemoteLaunchEvent(TaskAttemptId taskAttemptID,
ContainerLaunchContext containerLaunchContext,
Container allocatedContainer,
Task remoteTask) |
Copyright © 2013 Apache Software Foundation. All rights reserved.