diff --git a/engine-core/src/main/java/io/nosqlbench/engine/core/ScenarioResult.java b/engine-core/src/main/java/io/nosqlbench/engine/core/ScenarioResult.java index 61e491e01..c86330606 100644 --- a/engine-core/src/main/java/io/nosqlbench/engine/core/ScenarioResult.java +++ b/engine-core/src/main/java/io/nosqlbench/engine/core/ScenarioResult.java @@ -18,6 +18,7 @@ package io.nosqlbench.engine.core; +import com.codahale.metrics.ConsoleReporter; import com.codahale.metrics.MetricFilter; import io.nosqlbench.engine.api.metrics.ActivityMetrics; import io.nosqlbench.engine.core.logging.Log4JMetricsReporter; @@ -44,6 +45,7 @@ public class ScenarioResult { } public void reportToLog() { + logger.info("-- BEGIN METRICS DETAIL --"); Log4JMetricsReporter reporter = Log4JMetricsReporter.forRegistry(ActivityMetrics.getMetricRegistry()) .convertDurationsTo(TimeUnit.MICROSECONDS) @@ -56,13 +58,23 @@ public class ScenarioResult { } + public void reportToConsole() { + ConsoleReporter consoleReporter = ConsoleReporter.forRegistry(ActivityMetrics.getMetricRegistry()) + .convertDurationsTo(TimeUnit.MICROSECONDS) + .convertRatesTo(TimeUnit.SECONDS) + .filter(MetricFilter.ALL) + .outputTo(System.out) + .build(); + consoleReporter.report(); + } + public Optional getException() { return Optional.ofNullable(exception); } public void rethrowIfError() { - if (exception!=null) { + if (exception != null) { if (exception instanceof RuntimeException) { throw ((RuntimeException) exception); } else { @@ -74,4 +86,5 @@ public class ScenarioResult { public String getIOLog() { return this.iolog; } + } diff --git a/engine-core/src/main/java/io/nosqlbench/engine/core/ScenariosResults.java b/engine-core/src/main/java/io/nosqlbench/engine/core/ScenariosResults.java index bcaa05a26..12e07e822 100644 --- a/engine-core/src/main/java/io/nosqlbench/engine/core/ScenariosResults.java +++ b/engine-core/src/main/java/io/nosqlbench/engine/core/ScenariosResults.java @@ -67,9 +67,11 @@ public class ScenariosResults { if (oresult != null) { oresult.reportToLog(); + oresult.reportToConsole(); } else { logger.error(scenario.getScenarioName() + ": incomplete (missing result)"); } + } }