Home
last modified time | relevance | path

Searched defs:mapTaskId (Results 1 – 10 of 10) sorted by relevance

/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 DMapTaskStatus.java99 public void addFetchFailedMap(TaskAttemptID mapTaskId) { in addFetchFailedMap()
H A DReduceTaskStatus.java108 public void addFetchFailedMap(TaskAttemptID mapTaskId) { in addFetchFailedMap()
H A DTaskStatus.java367 public abstract void addFetchFailedMap(TaskAttemptID mapTaskId); in addFetchFailedMap()
/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 DLocalFetcher.java117 private boolean copyMapOutput(TaskAttemptID mapTaskId) throws IOException { in copyMapOutput()
H A DMergeManagerImpl.java451 TaskID mapTaskId = mapId.getTaskID(); in merge() local
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/
H A DReduceTaskStatus.java96 void addFetchFailedMap(TaskAttemptID mapTaskId) { in addFetchFailedMap()
H A DTaskStatus.java294 synchronized void addFetchFailedMap(TaskAttemptID mapTaskId) {} in addFetchFailedMap()
H A DReduceTask.java2243 TaskAttemptID mapTaskId = cr.getLocation().getTaskAttemptId(); in fetchOutputs() local
H A DJobInProgress.java3424 TaskAttemptID mapTaskId, in fetchFailureNotification()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/
H A DTestJobHistory.java633 TaskID mapTaskId = new TaskID(job.getID(), true, 0); in validateTaskLevelKeyValues() local