| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/test/java/org/apache/hadoop/mapreduce/v2/hs/ |
| H A D | MockHistoryJobs.java | 110 return job.getTotalMaps(); in getCompletedMaps()
189 public int getTotalMaps() { in getTotalMaps() method in MockHistoryJobs.MockCompletedJob
190 return job.getTotalMaps(); in getTotalMaps()
|
| H A D | TestJobHistoryParsing.java | 904 + jobInfo.getTotalMaps() + " " in testTaskAttemptUnsuccessfulCompletionWithoutCounters203()
922 + jobInfo.getTotalMaps() + " " in testTaskAttemptUnsuccessfulCompletionWithoutCounters240()
940 + jobInfo.getTotalMaps() + " " in testTaskAttemptUnsuccessfulCompletionWithoutCounters0239()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs/ |
| H A D | CompletedJob.java | 142 if ( getTotalMaps() == 0 ) { in constructJobReport()
145 report.setMapProgress((float) getCompletedMaps() / getTotalMaps()); in constructJobReport()
383 public int getTotalMaps() { in getTotalMaps() method in CompletedJob
384 return (int) jobInfo.getTotalMaps(); in getTotalMaps()
|
| H A D | PartialJob.java | 128 public int getTotalMaps() { in getTotalMaps() method in PartialJob
|
| /dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/rumen/ |
| H A D | JobInitedEvent.java | 56 public int getTotalMaps() { return totalMaps; } in getTotalMaps() method in JobInitedEvent
|
| H A D | ZombieJob.java | 190 int totalMaps = job.getTotalMaps(); in getInputSplits()
252 return sanitizeValue(job.getTotalMaps(), 0, "NumberMaps", job.getJobID()); in getNumberMaps()
|
| H A D | LoggedJob.java | 240 public int getTotalMaps() { in getTotalMaps() method in LoggedJob
|
| H A D | JobBuilder.java | 560 result.setTotalMaps(event.getTotalMaps()); in processJobInitedEvent()
|
| /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/jobhistory/ |
| H A D | JobInitedEvent.java | 65 public int getTotalMaps() { return datum.totalMaps; } in getTotalMaps() method in JobInitedEvent
|
| H A D | JobHistoryParser.java | 407 info.totalMaps = event.getTotalMaps(); in handleJobInitedEvent()
536 public long getTotalMaps() { return totalMaps; } in getTotalMaps() method in JobHistoryParser.JobInfo
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/ |
| H A D | Job.java | 63 int getTotalMaps(); in getTotalMaps() method
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/test/java/org/apache/hadoop/mapreduce/v2/hs/webapp/ |
| H A D | VerifyJobsUtils.java | 94 assertEquals("mapsTotal incorrect", job.getTotalMaps(), mapsTotal); in verifyHsJobGeneric()
|
| H A D | TestHsWebServicesAcls.java | 341 public int getTotalMaps() { in getTotalMaps() method in TestHsWebServicesAcls.MockJobForAcls
342 return mockJob.getTotalMaps(); in getTotalMaps()
|
| H A D | TestBlocks.java | 352 when(job.getTotalMaps()).thenReturn(3); in getJob()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/ |
| H A D | StartEndTimesBase.java | 134 ? job.getTotalMaps() : job.getTotalReduces(); in thresholdRuntime()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/webapp/dao/ |
| H A D | JobInfo.java | 102 this.mapsTotal = job.getTotalMaps(); in JobInfo()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs/webapp/dao/ |
| H A D | JobInfo.java | 85 this.mapsTotal = job.getTotalMaps(); in JobInfo()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-rumen/src/main/java/org/apache/hadoop/tools/rumen/ |
| H A D | ZombieJob.java | 192 int totalMaps = job.getTotalMaps(); in getInputSplits()
254 return sanitizeValue(job.getTotalMaps(), 0, "NumberMaps", job.getJobID()); in getNumberMaps()
|
| H A D | LoggedJob.java | 241 public int getTotalMaps() { in getTotalMaps() method in LoggedJob
|
| H A D | JobBuilder.java | 646 result.setTotalMaps(event.getTotalMaps()); in processJobInitedEvent()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapred/ |
| H A D | TestLocalContainerLauncher.java | 133 when(job.getTotalMaps()).thenReturn(1); in testKillJob()
|
| /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 | 267 int numMapTasks = job.getTotalMaps(); in runTask()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/jobhistory/ |
| H A D | JobHistoryEventHandler.java | 707 summary.setNumFinishedMaps(context.getJob(jobId).getTotalMaps()); in processEventForJobSummary()
764 tEvent.addEventInfo("TOTAL_MAPS", jie.getTotalMaps()); in processEventForTimelineServer()
|
| /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 | MockJobs.java | 545 public int getTotalMaps() {
|
| H A D | TestRuntimeEstimators.java | 480 public int getTotalMaps() { in getTotalMaps() method in TestRuntimeEstimators.MyJobImpl
|