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