IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

provide summary of scenarios results

Browse Source
This commit is contained in:
Jonathan Shook 2020-07-16 09:20:09 -05:00
parent 3afbaddf51
commit c93c17560b
1 changed files with 11 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
engine-core/src/main/java/io/nosqlbench/engine/core/ScenariosResults.java
View File

@ -30,11 +30,11 @@ public class ScenariosResults {
private static final Logger logger = LoggerFactory.getLogger(ScenariosResults.class);
private String scenariosExecutorName;
private Map<Scenario,ScenarioResult> scenarioResultMap = new LinkedHashMap<>();
private Map<Scenario, ScenarioResult> scenarioResultMap = new LinkedHashMap<>();
public ScenariosResults(ScenariosExecutor scenariosExecutor) {
this.scenariosExecutorName =scenariosExecutor.getName();
this.scenariosExecutorName = scenariosExecutor.getName();
}
public ScenariosResults(ScenariosExecutor scenariosExecutor, Map<Scenario, ScenarioResult> map) {
@ -42,24 +42,16 @@ public class ScenariosResults {
scenarioResultMap.putAll(map);
}
// public void reportSummaryTo(PrintStream out) {
// for (Map.Entry<Scenario, Result> entry : this.scenarioResultMap.entrySet()) {
// Scenario scenario = entry.getKey();
// Result oresult = entry.getValue();
//
// out.println("results for scenario: " + scenario);
//
// if (oresult!=null) {
// oresult.reportTo(out);
// } else {
// out.println(": incomplete (missing result)");
// }
// }
// }
public String getExecutionSummary() {
StringBuilder sb = new StringBuilder();
sb.append(scenarioResultMap.size()).append(" scenarios, ");
sb.append(scenarioResultMap.values().stream().filter(r -> r.getException().isEmpty()).count()).append(" normal, ");
sb.append(scenarioResultMap.values().stream().filter(r -> r.getException().isPresent()).count()).append(" errored");
return sb.toString();
}
public ScenarioResult getOne() {
if (this.scenarioResultMap.size()!=1) {
if (this.scenarioResultMap.size() != 1) {
throw new RuntimeException("getOne found " + this.scenarioResultMap.size() + " results instead of 1.");
}
return scenarioResultMap.values().stream().findFirst().orElseThrow(
@ -73,7 +65,7 @@ public class ScenariosResults {
logger.info("results for scenario: " + scenario);
if (oresult!=null) {
if (oresult != null) {
oresult.reportToLog();
} else {
logger.error(scenario.getName() + ": incomplete (missing result)");