IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2024-12-22 15:13:41 -06:00
Code Issues Packages Projects Releases Wiki Activity

making changes (#2093)

Browse Source
This commit is contained in:
sahankj2000 2024-11-20 21:07:14 +05:30 committed by GitHub
parent 6c5bc8dcc1
commit 2229f919a2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 36 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
nb-adapters/adapter-cqld4/src/main/java/io/nosqlbench/cqlgen/core/CGWorkloadExporter.java
View File

@ -235,17 +235,17 @@ public class CGWorkloadExporter implements BundledApp {
);
for (String component : components) {
Map<String, Object> additions = switch (component) {
case "schema-keyspaces" -> genCreateKeyspacesOpTemplates(model, blockname);
case "schema-tables" -> genCreateTablesOpTemplates(model, blockname);
case "schema-types" -> genCreateTypesOpTemplates(model, blockname);
case "drop-types" -> genDropTypesBlock(model, blockname);
case "drop-tables" -> genDropTablesBlock(model, blockname);
case "drop-keyspaces" -> genDropKeyspacesOpTemplates(model, blockname);
case "truncate-tables" -> genTruncateTablesOpTemplates(model, blockname);
case "insert-seq" -> genInsertOpTemplates(model, blockname);
case "select-seq" -> genSelectOpTemplates(model, blockname);
case "scan-10-seq" -> genScanOpTemplates(model, blockname);
case "update-seq" -> genUpdateOpTemplates(model, blockname);
case "schema_keyspaces" -> genCreateKeyspacesOpTemplates(model, blockname);
case "schema_tables" -> genCreateTablesOpTemplates(model, blockname);
case "schema_types" -> genCreateTypesOpTemplates(model, blockname);
case "drop_types" -> genDropTypesBlock(model, blockname);
case "drop_tables" -> genDropTablesBlock(model, blockname);
case "drop_keyspaces" -> genDropKeyspacesOpTemplates(model, blockname);
case "truncate_tables" -> genTruncateTablesOpTemplates(model, blockname);
case "insert_seq" -> genInsertOpTemplates(model, blockname);
case "select_seq" -> genSelectOpTemplates(model, blockname);
case "scan_10_seq" -> genScanOpTemplates(model, blockname);
case "update_seq" -> genUpdateOpTemplates(model, blockname);
default -> throw new RuntimeException("Unable to create block entries for " + component + ".");
};
block.putAll(additions);
@ -325,23 +325,23 @@ public class CGWorkloadExporter implements BundledApp {
put("default",
new LinkedHashMap<>() {{
put("schema", "run driver=cql tags=block:\"schema.*\" threads===UNDEF cycles===UNDEF");
put("rampup", "run driver=cql tags=block:rampup threads=auto cycles===TEMPLATE(rampup-cycles,10000)");
put("main", "run driver=cql tags=block:\"main.*\" threads=auto cycles===TEMPLATE(main-cycles,10000)");
put("rampup", "run driver=cql tags=block:rampup threads=auto cycles===TEMPLATE(rampup_cycles,10000)");
put("main", "run driver=cql tags=block:\"main.*\" threads=auto cycles===TEMPLATE(main_cycles,10000)");
}});
put("main-insert", "run driver=cql tags=block:main-insert threads=auto cycles===TEMPLATE(main-cycles,10000)");
put("main-select", "run driver=cql tags=block:main-select threads=auto cycles===TEMPLATE(main-cycles,10000)");
put("main-scan", "run driver=cql tags=block:main-scan threads=auto cycles===TEMPLATE(main-cycles,10000)");
put("main-update", "run driver=cql tags=block:main-update threads=auto cycles===TEMPLATE(main-cycles,10000)");
put("main_insert", "run driver=cql tags=block:main_insert threads=auto cycles===TEMPLATE(main_cycles,10000)");
put("main_select", "run driver=cql tags=block:main_select threads=auto cycles===TEMPLATE(main_cycles,10000)");
put("main_scan", "run driver=cql tags=block:main_scan threads=auto cycles===TEMPLATE(main_cycles,10000)");
put("main_update", "run driver=cql tags=block:main_update threads=auto cycles===TEMPLATE(main_cycles,10000)");
put("truncate", "run driver=cql tags=block:truncate.* threads===UNDEF cycles===UNDEF");
put("schema-keyspaces", "run driver=cql tags=block:schema-keyspaces threads===UNDEF cycles===UNDEF");
put("schema-types", "run driver=cql tags=block:schema-types threads===UNDEF cycles===UNDEF");
put("schema-tables", "run driver=cql tags=block:schema-tables threads===UNDEF cycles===UNDEF");
put("schema_keyspaces", "run driver=cql tags=block:schema_keyspaces threads===UNDEF cycles===UNDEF");
put("schema_types", "run driver=cql tags=block:schema_types threads===UNDEF cycles===UNDEF");
put("schema_tables", "run driver=cql tags=block:schema_tables threads===UNDEF cycles===UNDEF");
put("drop", "run driver=cql tags=block:drop.* threads===UNDEF cycles===UNDEF");
put("drop-tables", "run driver=cql tags=block:drop-tables threads===UNDEF cycles===UNDEF");
put("drop-types", "run driver=cql tags=block:drop-types threads===UNDEF cycles===UNDEF");
put("drop-keyspaces", "run driver=cql tags=block:drop-keyspaces threads===UNDEF cycles===UNDEF");
put("drop_tables", "run driver=cql tags=block:drop_tables threads===UNDEF cycles===UNDEF");
put("drop_types", "run driver=cql tags=block:drop_types threads===UNDEF cycles===UNDEF");
put("drop_keyspaces", "run driver=cql tags=block:drop_keyspaces threads===UNDEF cycles===UNDEF");
}};
}

26
nb-adapters/adapter-cqld4/src/main/resources/cqlgen/cqlgen.conf
View File

@ -94,7 +94,7 @@ model_transformers:
# This affects block names, op template names and so on, and also how
# op templates will be named in all logs and metric views.
naming_template: "[OPTYPE-][TYPE-][KEYSPACE-][TABLE-][NAME]"
naming_template: "[OPTYPE_][TYPE_][KEYSPACE_][TABLE_][NAME]"
# for more distinction in metric names if needed:
#naming_template: "[BLOCKNAME-][OPTYPE-][KEYSPACE-][TYPE-][NAME]"
@ -128,20 +128,20 @@ timeouts:
blockplan:
# not needed when tags=block:"schema.*"
# schema: schema-keyspaces, schema-tables, schema-types
schema-keyspaces: schema-keyspaces
schema-tables: schema-tables
schema-types: schema-types
truncate-tables: truncate-tables
drop-types: drop-types
drop-tables: drop-tables
drop-keyspaces: drop-keyspaces
schema_keyspaces: schema_keyspaces
schema_tables: schema_tables
schema_types: schema_types
truncate_tables: truncate_tables
drop_types: drop_types
drop_tables: drop_tables
drop_keyspaces: drop_keyspaces
# not needed when tags=block:'drop.*'
# drop: drop-types, drop-tables, drop-keyspaces
rampup: insert-seq
main-insert: insert-seq
main-select: select-seq
main-scan: scan-10-seq
main-update: update-seq
rampup: insert_seq
main_insert: insert_seq
main_select: select_seq
main_scan: scan_10_seq
main_update: update_seq
# not needed when tags=block:'main.*'
# main: insert, select, scan-10, update