| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/ |
| H A D | TaskAttemptID.java | 50 public class TaskAttemptID extends org.apache.hadoop.mapred.ID { class
59 public TaskAttemptID(TaskID taskId, int id) { in TaskAttemptID() method in TaskAttemptID
75 public TaskAttemptID(String jtIdentifier, int jobId, TaskType type, in TaskAttemptID() method in TaskAttemptID
89 public TaskAttemptID(String jtIdentifier, int jobId, boolean isMap, in TaskAttemptID() method in TaskAttemptID
94 public TaskAttemptID() { in TaskAttemptID() method in TaskAttemptID
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/ |
| H A D | TaskAttemptID.java | 50 public class TaskAttemptID extends org.apache.hadoop.mapreduce.TaskAttemptID { class
57 public TaskAttemptID(TaskID taskId, int id) { in TaskAttemptID() method in TaskAttemptID
71 public TaskAttemptID(String jtIdentifier, int jobId, boolean isMap, in TaskAttemptID() method in TaskAttemptID
85 public TaskAttemptID(String jtIdentifier, int jobId, TaskType type, in TaskAttemptID() method in TaskAttemptID
90 public TaskAttemptID() { in TaskAttemptID() method in TaskAttemptID
|
| H A D | ShuffleConsumerPlugin.java | 87 Map<TaskAttemptID, MapOutputFile> localMapFiles) { in Context()
|
| H A D | ReduceTask.java | 148 public void setLocalMapFiles(Map<TaskAttemptID, MapOutputFile> mapFiles) { in setLocalMapFiles()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/ |
| H A D | TaskAttemptID.java | 45 public class TaskAttemptID extends org.apache.hadoop.mapred.ID { class
54 public TaskAttemptID(TaskID taskId, int id) { in TaskAttemptID() method in TaskAttemptID
70 public TaskAttemptID(String jtIdentifier, int jobId, boolean isMap, in TaskAttemptID() method in TaskAttemptID
75 public TaskAttemptID() { in TaskAttemptID() method in TaskAttemptID
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
| H A D | TaskAttemptID.java | 44 public class TaskAttemptID extends org.apache.hadoop.mapreduce.TaskAttemptID { class
51 public TaskAttemptID(TaskID taskId, int id) { in TaskAttemptID() method in TaskAttemptID
63 public TaskAttemptID(String jtIdentifier, int jobId, boolean isMap, in TaskAttemptID() method in TaskAttemptID
68 public TaskAttemptID() { in TaskAttemptID() method in TaskAttemptID
|
| H A D | LocalJobRunner.java | 192 Map<TaskAttemptID, MapOutputFile> mapOutputFiles) { in MapTaskRunnable()
246 Map<TaskAttemptID, MapOutputFile> mapOutputFiles) { in getMapTaskRunnables()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/ |
| H A D | LocalContainerLauncher.java | 263 Map<TaskAttemptID, MapOutputFile> localMapFiles) { in runTask()
335 Map<TaskAttemptID, MapOutputFile> localMapFiles) in runSubtask()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/ |
| H A D | LocalFetcher.java | 60 Map<TaskAttemptID, MapOutputFile> localMapFiles) { in LocalFetcher()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapred/ |
| H A D | LocalJobRunner.java | 212 Map<TaskAttemptID, MapOutputFile> mapOutputFiles) { in MapTaskRunnable()
266 Map<TaskAttemptID, MapOutputFile> mapOutputFiles) { in getMapTaskRunnables()
290 Map<TaskAttemptID, MapOutputFile> mapOutputFiles) { in ReduceTaskRunnable()
344 JobID jobId, Map<TaskAttemptID, MapOutputFile> mapOutputFiles) { in getReduceTaskRunnables()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/ |
| H A D | TestRecovery.java | 1711 Map<TaskAttemptID, TaskAttemptState> finalAttemptStates, in recoveryChecker()
|