in src/main/java/org/apache/accumulo/testing/continuous/UndefinedAnalyzer.java [89:128]
private void parseLog(File log) throws Exception {
String line;
TreeMap<Long,Long> tm = null;
try (BufferedReader reader = Files.newBufferedReader(log.toPath())) {
while ((line = reader.readLine()) != null) {
if (!line.startsWith("UUID"))
continue;
String[] tokens = line.split("\\s");
String time = tokens[1];
String uuid = tokens[2];
if (flushes.containsKey(uuid)) {
logger.error("WARN Duplicate uuid " + log);
return;
}
tm = new TreeMap<>(Collections.reverseOrder());
tm.put(0L, Long.parseLong(time));
flushes.put(uuid, tm);
break;
}
if (tm == null) {
logger.error("WARN Bad ingest log " + log);
return;
}
while ((line = reader.readLine()) != null) {
String[] tokens = line.split("\\s");
if (!tokens[0].equals("FLUSH"))
continue;
String time = tokens[1];
String count = tokens[4];
tm.put(Long.parseLong(count), Long.parseLong(time));
}
}
}