diff --git a/pdb-plotting/src/main/java/org/lucares/recommind/logs/TcpIngestor.java b/pdb-plotting/src/main/java/org/lucares/recommind/logs/TcpIngestor.java index 0f756d1..9c862e7 100644 --- a/pdb-plotting/src/main/java/org/lucares/recommind/logs/TcpIngestor.java +++ b/pdb-plotting/src/main/java/org/lucares/recommind/logs/TcpIngestor.java @@ -72,11 +72,11 @@ public class TcpIngestor implements AutoCloseable { System.out.println("reading from stream"); while (iterator.hasNext()) { + final long start = System.nanoTime(); // System.out.println("read: " + line); @SuppressWarnings("unchecked") final Map object = (Map) iterator.next(); - final long start = System.nanoTime(); final Optional entry = createEntry(object); final long end = System.nanoTime(); duration += (end - start) / 1_000_000.0; diff --git a/performanceDb/src/main/java/org/lucares/performance/db/PdbWriterManager.java b/performanceDb/src/main/java/org/lucares/performance/db/PdbWriterManager.java index 34af55c..41ebf4e 100644 --- a/performanceDb/src/main/java/org/lucares/performance/db/PdbWriterManager.java +++ b/performanceDb/src/main/java/org/lucares/performance/db/PdbWriterManager.java @@ -88,6 +88,7 @@ public class PdbWriterManager implements AutoCloseable { final Day day = new Day(date); if (!day.equals(lastDay)) { + LOGGER.info("finished with " + day); closeFiles(); lastDay = day; } @@ -115,7 +116,6 @@ public class PdbWriterManager implements AutoCloseable { } private void closeFiles() { - LOGGER.info("closing all files"); final Iterator> it = map.entrySet().iterator(); while (it.hasNext()) { diff --git a/performanceDb/src/main/java/org/lucares/performance/db/TagsToFile.java b/performanceDb/src/main/java/org/lucares/performance/db/TagsToFile.java index ddc60c5..9e63a32 100644 --- a/performanceDb/src/main/java/org/lucares/performance/db/TagsToFile.java +++ b/performanceDb/src/main/java/org/lucares/performance/db/TagsToFile.java @@ -167,14 +167,11 @@ public class TagsToFile implements CollectionUtils { final Document document = db.getDocument(tagSpecificStorageFolder.toFile()); if (document == null) { - System.err.println("adding new folder: " + tagSpecificStorageFolder); db.addDocument(tagSpecificStorageFolder.toFile()); tags.forEach((fieldName, value) -> { TagsUtils.setProperty(db, tagSpecificStorageFolder.toFile(), fieldName, value); }); - } else { - System.out.println("using existing folder: " + tagSpecificStorageFolder); } result = new PdbFile(day, storageFile, tags);