* @version $Id: DailyLatencyReport.java,v 1.2 2013/11/06 16:23:54 eby Exp $\r
*/\r
public class DailyLatencyReport extends ReportBase {\r
* @version $Id: DailyLatencyReport.java,v 1.2 2013/11/06 16:23:54 eby Exp $\r
*/\r
public class DailyLatencyReport extends ReportBase {\r
private static final String SELECT_SQL =\r
"select EVENT_TIME, TYPE, PUBLISH_ID, FEED_FILEID, FEEDID, CONTENT_LENGTH from LOG_RECORDS" +\r
private static final String SELECT_SQL =\r
"select EVENT_TIME, TYPE, PUBLISH_ID, FEED_FILEID, FEEDID, CONTENT_LENGTH from LOG_RECORDS" +\r
- for (Long l : deltime)\r
- n = Math.min(n, l-pubtime);\r
+ for (Long l : deltime) {\r
+ n = Math.min(n, l - pubtime);\r
+ }\r
- for (Long l : deltime)\r
- n = Math.max(n, l-pubtime);\r
+ for (Long l : deltime) {\r
+ n = Math.max(n, l - pubtime);\r
+ }\r
public final String date;\r
public final int feedid;\r
public final Map<String, Job> jobs;\r
public final String date;\r
public final int feedid;\r
public final Map<String, Job> jobs;\r
public void addEvent(long etime, String type, String id, String fid, long clen) {\r
Job j = jobs.get(id);\r
if (j == null) {\r
public void addEvent(long etime, String type, String id, String fid, long clen) {\r
Job j = jobs.get(id);\r
if (j == null) {\r
@Override\r
public String toString() {\r
long minsize = Long.MAX_VALUE, maxsize = 0, avgsize = 0;\r
@Override\r
public String toString() {\r
long minsize = Long.MAX_VALUE, maxsize = 0, avgsize = 0;\r
- long minl = Long.MAX_VALUE, maxl = 0;\r
- long fanout = 0, totall = 0, totaln = 0;\r
+ long minl = Long.MAX_VALUE, maxl = 0;\r
+ long fanout = 0, totall = 0, totaln = 0;\r
for (Job j : jobs.values()) {\r
minsize = Math.min(minsize, j.clen);\r
maxsize = Math.max(maxsize, j.clen);\r
avgsize += j.clen;\r
for (Job j : jobs.values()) {\r
minsize = Math.min(minsize, j.clen);\r
maxsize = Math.max(maxsize, j.clen);\r
avgsize += j.clen;\r
- minl = Math.min(minl, j.minLatency());\r
- maxl = Math.max(maxl, j.maxLatency());\r
- totall += j.totalLatency();\r
- totaln += j.deltime.size();\r
- fanout += j.deltime.size();\r
+ minl = Math.min(minl, j.minLatency());\r
+ maxl = Math.max(maxl, j.maxLatency());\r
+ totall += j.totalLatency();\r
+ totaln += j.deltime.size();\r
+ fanout += j.deltime.size();\r
- return date + "," + feedid + "," + minsize + "," + maxsize + "," + avgsize + "," + minl + "," + maxl + "," + avgl + "," + fanout;\r
+ return date + "," + feedid + "," + minsize + "," + maxsize + "," + avgsize + "," + minl + "," + maxl + ","\r
+ + avgl + "," + fanout;\r
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");\r
long start = System.currentTimeMillis();\r
try {\r
DB db = new DB();\r
@SuppressWarnings("resource")\r
Connection conn = db.getConnection();\r
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");\r
long start = System.currentTimeMillis();\r
try {\r
DB db = new DB();\r
@SuppressWarnings("resource")\r
Connection conn = db.getConnection();\r
- logger.debug("Query time: " + (System.currentTimeMillis()-start) + " ms");\r
- try (PrintWriter os = new PrintWriter(outfile)){\r
+ logger.debug("Query time: " + (System.currentTimeMillis() - start) + " ms");\r
+ try (PrintWriter os = new PrintWriter(outfile)) {\r
os.println("date,feedid,minsize,maxsize,avgsize,minlat,maxlat,avglat,fanout");\r
os.println("date,feedid,minsize,maxsize,avgsize,minlat,maxlat,avglat,fanout");\r
Counters c = map.get(key);\r
os.println(c.toString());\r
}\r
} catch (FileNotFoundException e) {\r
Counters c = map.get(key);\r
os.println(c.toString());\r
}\r
} catch (FileNotFoundException e) {\r