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

support mapped blocks

Browse Source
This commit is contained in:
Jonathan Shook 2021-03-10 13:00:40 -06:00
parent 2785670371
commit 63158fcdd1
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
engine-api/src/main/java/io/nosqlbench/engine/api/activityconfig/rawyaml/RawStmtsDoc.java
View File

@ -59,6 +59,24 @@ public class RawStmtsDoc extends StatementsOwner {
throw new RuntimeException("Invalid object type for block data: " + blockData.getClass().getCanonicalName()); throw new RuntimeException("Invalid object type for block data: " + blockData.getClass().getCanonicalName());
} }
} }
} else if (blocksObjects instanceof Map) {
Map<String, Object> blockDataAsMap = (Map<String, Object>) blocksObjects;
for (Map.Entry<String, Object> entry : blockDataAsMap.entrySet()) {
String blockName = entry.getKey();
Object blockData = entry.getValue();
if (blockData instanceof Map) {
Map<String, Object> blockDataMap = (Map<String, Object>) blockData;
RawStmtsBlock rawStmtsBlock = new RawStmtsBlock();
rawStmtsBlock.setName(blockName);
rawStmtsBlock.setFieldsByReflection(blockDataMap);
blocks.add(rawStmtsBlock);
} else {
throw new RuntimeException("Invalid object type for block data: " + blockData.getClass().getCanonicalName());
}
}
} else if (blocksObjects != null) {
throw new RuntimeException("Type of blocks interior data type not recognized:" + blocksObjects.getClass().getCanonicalName());
} }
Object scenariosData = properties.remove("scenarios"); Object scenariosData = properties.remove("scenarios");