andi/perfdb
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Activity

add metric logging for getWriter

Browse Source
This commit is contained in:
ahr
2018-01-13 10:32:03 +01:00
parent 0f2fcc3c9c
commit 64613ce43c
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
performanceDb/src/main/java/org/lucares/performance/db/TagsToFile.java
View File

@@ -26,6 +26,7 @@ import org.slf4j.LoggerFactory;
public class TagsToFile implements AutoCloseable { public class TagsToFile implements AutoCloseable {
private static final Logger LOGGER = LoggerFactory.getLogger(TagsToFile.class); private static final Logger LOGGER = LoggerFactory.getLogger(TagsToFile.class);
private final static Logger METRICS_LOGGER = LoggerFactory.getLogger("org.lucares.metrics.ingestion.tagsToFile");
private static class WriterCache { private static class WriterCache {
final List<PdbWriter> writers = new ArrayList<>(); final List<PdbWriter> writers = new ArrayList<>();
@@ -93,6 +94,7 @@ public class TagsToFile implements AutoCloseable {
result = optionalWriter.get(); result = optionalWriter.get();
LOGGER.trace("using existing pdbWriter: {}", result); LOGGER.trace("using existing pdbWriter: {}", result);
} else { } else {
final long start = System.nanoTime();
final List<PdbFile> pdbFiles = getFilesMatchingTagsExactly(tags); final List<PdbFile> pdbFiles = getFilesMatchingTagsExactly(tags);
assertAllFilesHaveSameFolder(pdbFiles); assertAllFilesHaveSameFolder(pdbFiles);
@@ -102,6 +104,9 @@ public class TagsToFile implements AutoCloseable {
final List<Optional<PdbWriter>> existingWriters = CollectionUtils.filter(optionalWriters, final List<Optional<PdbWriter>> existingWriters = CollectionUtils.filter(optionalWriters,
Optional::isPresent); Optional::isPresent);
final List<PdbWriter> writers = CollectionUtils.map(existingWriters, Optional::get); final List<PdbWriter> writers = CollectionUtils.map(existingWriters, Optional::get);
METRICS_LOGGER.debug("find writers took {}ms for tags {}", (System.nanoTime() - start)
/ 1_000_000.0, tags);
final Optional<PdbWriter> optionalFirst = chooseBestMatchingWriter(writers, date); final Optional<PdbWriter> optionalFirst = chooseBestMatchingWriter(writers, date);