01: package org.apache.lucene.benchmark.byTask.tasks;
02:
03: /**
04: * Licensed to the Apache Software Foundation (ASF) under one or more
05: * contributor license agreements. See the NOTICE file distributed with
06: * this work for additional information regarding copyright ownership.
07: * The ASF licenses this file to You under the Apache License, Version 2.0
08: * (the "License"); you may not use this file except in compliance with
09: * the License. You may obtain a copy of the License at
10: *
11: * http://www.apache.org/licenses/LICENSE-2.0
12: *
13: * Unless required by applicable law or agreed to in writing, software
14: * distributed under the License is distributed on an "AS IS" BASIS,
15: * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16: * See the License for the specific language governing permissions and
17: * limitations under the License.
18: */
19:
20: import java.util.Iterator;
21: import java.util.LinkedHashMap;
22: import java.util.List;
23:
24: import org.apache.lucene.benchmark.byTask.PerfRunData;
25: import org.apache.lucene.benchmark.byTask.stats.Report;
26: import org.apache.lucene.benchmark.byTask.stats.TaskStats;
27:
28: /**
29: * Report all statistics aggregated by name.
30: * <br>Other side effects: None.
31: */
32: public class RepSumByNameTask extends ReportTask {
33:
34: public RepSumByNameTask(PerfRunData runData) {
35: super (runData);
36: }
37:
38: public int doLogic() throws Exception {
39: Report rp = reportSumByName(getRunData().getPoints()
40: .taskStats());
41:
42: System.out.println();
43: System.out.println("------------> Report Sum By (any) Name ("
44: + rp.getSize() + " about " + rp.getReported()
45: + " out of " + rp.getOutOf() + ")");
46: System.out.println(rp.getText());
47: System.out.println();
48:
49: return 0;
50: }
51:
52: /**
53: * Report statistics as a string, aggregate for tasks named the same.
54: * @return the report
55: */
56: protected Report reportSumByName(List taskStats) {
57: // aggregate by task name
58: int reported = 0;
59: LinkedHashMap p2 = new LinkedHashMap();
60: for (Iterator it = taskStats.iterator(); it.hasNext();) {
61: TaskStats stat1 = (TaskStats) it.next();
62: if (stat1.getElapsed() >= 0) { // consider only tasks that ended
63: reported++;
64: String name = stat1.getTask().getName();
65: TaskStats stat2 = (TaskStats) p2.get(name);
66: if (stat2 == null) {
67: try {
68: stat2 = (TaskStats) stat1.clone();
69: } catch (CloneNotSupportedException e) {
70: throw new RuntimeException(e);
71: }
72: p2.put(name, stat2);
73: } else {
74: stat2.add(stat1);
75: }
76: }
77: }
78: // now generate report from secondary list p2
79: return genPartialReport(reported, p2, taskStats.size());
80: }
81:
82: }
|