| /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 | JobFinishedEvent.java | 44 private Counters reduceCounters; field in JobFinishedEvent
62 Counters mapCounters, Counters reduceCounters, in JobFinishedEvent() argument
71 this.reduceCounters = reduceCounters; in JobFinishedEvent()
87 datum.reduceCounters = EventWriter.toAvro(reduceCounters, in getDatum()
103 this.reduceCounters = EventReader.fromAvro(datum.reduceCounters); in setDatum()
133 return reduceCounters; in getReduceCounters()
|
| H A D | JobHistoryParser.java | 393 info.reduceCounters = event.getReduceCounters(); in handleJobFinishedEvent()
464 Counters reduceCounters; field in JobHistoryParser.JobInfo
502 if (reduceCounters != null) { in printAll()
503 System.out.println("REDUCE_COUNTERS:" + reduceCounters.toString()); in printAll()
555 public Counters getReduceCounters() { return reduceCounters; } in getReduceCounters()
|
| H A D | HistoryViewer.java | 159 Counters mapCounters, Counters reduceCounters) { in printCounters() argument
176 CounterGroup reduceGroup = reduceCounters.getGroup(groupName); in printCounters()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/rumen/ |
| H A D | JobFinishedEvent.java | 38 private Counters reduceCounters; field in JobFinishedEvent
56 Counters mapCounters, Counters reduceCounters, in JobFinishedEvent() argument
65 this.reduceCounters = reduceCounters; in JobFinishedEvent()
95 return reduceCounters; in getReduceCounters()
|
| H A D | ParsedJob.java | 84 void putReduceCounters(Map<String, Long> reduceCounters) { in putReduceCounters() argument
85 this.reduceCountersMap = reduceCounters; in putReduceCounters()
|
| H A D | Job20LineHistoryEventEmitter.java | 240 String reduceCounters = line.get("REDUCE_COUNTERS"); in maybeEmitEvent() local
249 maybeParseCounters(mapCounters), maybeParseCounters(reduceCounters), in maybeEmitEvent()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-rumen/src/main/java/org/apache/hadoop/tools/rumen/ |
| H A D | ParsedJob.java | 84 void putReduceCounters(Map<String, Long> reduceCounters) { in putReduceCounters() argument
85 this.reduceCountersMap = reduceCounters; in putReduceCounters()
|
| H A D | JobBuilder.java | 665 countersMap = JobHistoryUtils.extractCounters(job.reduceCounters); in processJobFinishedEvent()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/gridmix/src/test/system/org/apache/hadoop/mapred/gridmix/test/system/ |
| H A D | GridmixJobVerification.java | 221 Map<String,Long> reduceCounters, JobConf jobConf) throws ParseException { in verifyJobReduceCounters() argument
305 Map<String,Long> reduceCounters = new HashMap<String,Long>(); in getJobReduceCounters() local
313 reduceCounters.put("REDUCE_INPUT_BYTES", expReduceInputBytes); in getJobReduceCounters()
314 reduceCounters.put("REDUCE_OUTPUT_BYTES", expReduceOutputBytes); in getJobReduceCounters()
315 reduceCounters.put("REDUCE_INPUT_RECS", expReduceInputRecs); in getJobReduceCounters()
316 reduceCounters.put("REDUCE_OUTPUT_RECS", expReduceOutputRecs); in getJobReduceCounters()
317 return reduceCounters; in getJobReduceCounters()
531 Counters reduceCounters = in verifyMemoryEmulationOfJobs() local
541 getCounterValue(reduceCounters, in verifyMemoryEmulationOfJobs()
617 Counters reduceCounters = Counters.fromEscapedCompactString( in getSimulatedJobCPUMetrics() local
[all …]
|
| /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 | 126 private Counters [] reduceCounters; field in LocalJobRunner.Job
370 this.reduceCounters = new Counters[numReduces]; in initCounters()
372 this.reduceCounters[i] = new Counters(); in initCounters()
611 reduceCounters[reduceTaskIndex] = taskStatus.getCounters(); in statusUpdate()
638 if (null != reduceCounters && reduceCounters.length > 0) { in getCurrentCounters()
639 for (Counters c : reduceCounters) { in getCurrentCounters()
|
| /dports/devel/hadoop/hadoop-1.2.1/webapps/job/ |
| H A D | jobdetails.jsp | 462 Counters reduceCounters = new Counters();
463 isFine = jip.getReduceCounters(reduceCounters);
464 reduceCounters = (isFine? reduceCounters: new Counters());
474 Counters.Group reduceGroup = reduceCounters.getGroup(groupName);
825 Counters reduceCounters = new Counters();
826 isFine = job.getReduceCounters(reduceCounters);
827 reduceCounters = (isFine? reduceCounters: new Counters());
835 Counters.Group reduceGroup = reduceCounters.getGroup(groupName);
|
| H A D | jobdetailshistory.jsp | 248 Counters reduceCounters =
255 Counters.Group reduceGroup = reduceCounters.getGroup(groupName);
|
| /dports/devel/hadoop/hadoop-1.2.1/src/webapps/job/ |
| H A D | jobdetails.jsp | 462 Counters reduceCounters = new Counters();
463 isFine = jip.getReduceCounters(reduceCounters);
464 reduceCounters = (isFine? reduceCounters: new Counters());
474 Counters.Group reduceGroup = reduceCounters.getGroup(groupName);
825 Counters reduceCounters = new Counters();
826 isFine = job.getReduceCounters(reduceCounters);
827 reduceCounters = (isFine? reduceCounters: new Counters());
835 Counters.Group reduceGroup = reduceCounters.getGroup(groupName);
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
| H A D | LocalJobRunner.java | 97 private Counters reduceCounters; field in LocalJobRunner.Job
271 this.reduceCounters = new Counters(); in initCounters()
478 reduceCounters = taskStatus.getCounters(); in statusUpdate()
500 current = Counters.sum(current, reduceCounters); in getCurrentCounters()
|
| H A D | HistoryViewer.java | 163 Counters reduceCounters = in printCounters() local
184 Group reduceGroup = reduceCounters.getGroup(groupName); in printCounters()
|
| H A D | JobInProgress.java | 2809 Counters reduceCounters = new Counters(); in jobComplete() local
2810 isFine = getReduceCounters(reduceCounters);; in jobComplete()
2811 reduceCounters = (isFine ? reduceCounters: new Counters()); in jobComplete()
2821 reduceCounters, jobCounters); in jobComplete() local
|
| H A D | JobHistory.java | 1948 Counters reduceCounters, in logFinished() argument
1968 reduceCounters.makeEscapedCompactString(), in logFinished()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/webapps/history/ |
| H A D | jobdetailshistory.jsp | 248 Counters reduceCounters =
255 Counters.Group reduceGroup = reduceCounters.getGroup(groupName);
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/avro/ |
| H A D | Events.avpr | 57 {"name": "reduceCounters", "type": "JhCounters"}
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/test/resources/ |
| H A D | job_1416424547277_0002-1416424775281-root-TeraGen-1416424785433-2-0-SUCCEEDED-default-1416424779349.jhist | 2 …ong"}]}}}]}}}]}},{"name":"mapCounters","type":"JhCounters"},{"name":"reduceCounters","type":"JhCou…
29 …e":"BYTES_WRITTEN","displayName":"Bytes Written","value":10000}]}]},"reduceCounters":{"name":"REDU…
|
| H A D | job_1393307629410_0001-1393307687476-user-Sleep+job-1393307723835-0-0-FAILED-default-1393307693920.jhist | 2 …ong"}]}}}]}}}]}},{"name":"mapCounters","type":"JhCounters"},{"name":"reduceCounters","type":"JhCou…
|
| H A D | job_2.0.3-alpha-FAILED.jhist | 2 …ong"}]}}}]}}}]}},{"name":"mapCounters","type":"JhCounters"},{"name":"reduceCounters","type":"JhCou…
|
| H A D | job_2.4.0-FAILED.jhist | 2 …ong"}]}}}]}}}]}},{"name":"mapCounters","type":"JhCounters"},{"name":"reduceCounters","type":"JhCou…
|
| H A D | job_0.23.9-FAILED.jhist | 2 …ong"}]}}}]}}}]}},{"name":"mapCounters","type":"JhCounters"},{"name":"reduceCounters","type":"JhCou…
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/resources/ |
| H A D | job_1329348432655_0001-10.jhist | 2 …ong"}]}}}]}}}]}},{"name":"mapCounters","type":"JhCounters"},{"name":"reduceCounters","type":"JhCou…
51 …ts":[{"name":"BYTES_READ","displayName":"Bytes Read","value":0}]}]},"reduceCounters":{"name":"REDU…
|