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 grouped/aggregated by name and round.
30: * <br>Other side effects: None.
31: */
32: public class RepSumByNameRoundTask extends ReportTask {
33:
34: public RepSumByNameRoundTask(PerfRunData runData) {
35: super (runData);
36: }
37:
38: public int doLogic() throws Exception {
39: Report rp = reportSumByNameRound(getRunData().getPoints()
40: .taskStats());
41:
42: System.out.println();
43: System.out
44: .println("------------> Report Sum By (any) Name and Round ("
45: + rp.getSize()
46: + " about "
47: + rp.getReported()
48: + " out of " + rp.getOutOf() + ")");
49: System.out.println(rp.getText());
50: System.out.println();
51:
52: return 0;
53: }
54:
55: /**
56: * Report statistics as a string, aggregate for tasks named the same, and from the same round.
57: * @return the report
58: */
59: protected Report reportSumByNameRound(List taskStats) {
60: // aggregate by task name and round
61: LinkedHashMap p2 = new LinkedHashMap();
62: int reported = 0;
63: for (Iterator it = taskStats.iterator(); it.hasNext();) {
64: TaskStats stat1 = (TaskStats) it.next();
65: if (stat1.getElapsed() >= 0) { // consider only tasks that ended
66: reported++;
67: String name = stat1.getTask().getName();
68: String rname = stat1.getRound() + "." + name; // group by round
69: TaskStats stat2 = (TaskStats) p2.get(rname);
70: if (stat2 == null) {
71: try {
72: stat2 = (TaskStats) stat1.clone();
73: } catch (CloneNotSupportedException e) {
74: throw new RuntimeException(e);
75: }
76: p2.put(rname, stat2);
77: } else {
78: stat2.add(stat1);
79: }
80: }
81: }
82: // now generate report from secondary list p2
83: return genPartialReport(reported, p2, taskStats.size());
84: }
85:
86: }
|