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

improve ParsedOp api

Browse Source
This commit is contained in:
Jonathan Shook 2021-12-20 10:03:41 -06:00
parent 0b0602c436
commit 4420e56cfb
4 changed files with 20 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
adapters-api/src/main/java/io/nosqlbench/engine/api/templating/NamedTarget.java Normal file
View File

@ -0,0 +1,15 @@
package io.nosqlbench.engine.api.templating;
import java.util.function.LongFunction;
public class NamedTarget<E extends Enum<E>> {
public final E enumId;
public final String field;
public final LongFunction<?> targetFunction;
public NamedTarget(E enumId, String matchingOpFieldName, LongFunction<?> value) {
this.enumId = enumId;
this.field = matchingOpFieldName;
this.targetFunction = value;
}
}

4
driver-directapi/src/main/java/io/nosqlbench/driver/direct/DirectOpMapper.java
View File

@ -20,7 +20,7 @@ public class DirectOpMapper implements OpMapper<DirectCall> {
@Override
public OpDispenser<DirectCall> apply(ParsedOp cmd) {
String pkg = cmd.getOptionalValue("package", String.class).orElse("java.lang");
String pkg = cmd.getOptionalStaticValue("package", String.class).orElse("java.lang");
String cls = cmd.getStaticValue("class");
String fq = pkg + "." + cls;
Class<?> clazz = null;
@ -30,7 +30,7 @@ public class DirectOpMapper implements OpMapper<DirectCall> {
Class<?> finalClazz = clazz;
Optional<Field> staticfield =
cmd.getOptionalValue("staticfield", String.class)
cmd.getOptionalStaticValue("staticfield", String.class)
.map(name -> {
try {
return finalClazz.getDeclaredField(name);

2
driver-stdout/src/main/java/io/nosqlbench/adapters/stdout/StdoutOpDispenser.java
View File

@ -11,7 +11,7 @@ public class StdoutOpDispenser implements OpDispenser<StdoutOp> {
private final LongFunction<?> objectFunction;
public StdoutOpDispenser(ParsedOp cmd, LongFunction<StdoutSpace> ctxfunc) {
objectFunction = cmd.getAsFunction("stmt", Object.class);
objectFunction = cmd.getAsRequiredFunction("stmt", Object.class);
this.ctxfunc = ctxfunc;
}

4
nb-api/src/main/java/io/nosqlbench/nb/api/config/fieldreaders/StaticFieldReader.java
View File

@ -29,7 +29,7 @@ public interface StaticFieldReader {
<T> T getStaticValueOr(String name, T defaultValue);
<T> Optional<T> getOptionalValue(String field, Class<T> classOfT);
<T> Optional<T> getOptionalStaticValue(String field, Class<T> classOfT);
void assertDefinedStatic(String... fields);
// void assertDefinedStatic(String... fields);
}