Home
last modified time | relevance | path

Searched refs:myAttemptID (Results 1 – 1 of 1) sorted by relevance

/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 DTestRuntimeEstimators.java537 private final TaskAttemptId myAttemptID; field in TestRuntimeEstimators.MyTaskAttemptImpl
546 myAttemptID = recordFactory.newRecordInstance(TaskAttemptId.class); in MyTaskAttemptImpl()
547 myAttemptID.setId(index); in MyTaskAttemptImpl()
548 myAttemptID.setTaskId(taskID); in MyTaskAttemptImpl()
555 slotsInUse.addAndGet(taskTypeSlots(myAttemptID.getTaskId().getTaskType())); in startUp()
570 return myAttemptID; in getID()
594 int taskIndex = myAttemptID.getTaskId().getId(); in getCodeRuntime()
595 int attemptIndex = myAttemptID.getId(); in getCodeRuntime()
630 Job job = myAppContext.getJob(myAttemptID.getTaskId().getJobId()); in getReduceProgress()
685 (myAttemptID.getTaskId().getTaskType() == TaskType.MAP in getState()
[all …]