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

set defaults from sequence

Browse Source
This commit is contained in:
Jonathan Shook 2021-07-08 12:34:18 -05:00
parent 7ebac51044
commit 1f377926b6
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
engine-api/src/main/java/io/nosqlbench/engine/api/activityimpl/uniform/StandardActivity.java
View File

@ -25,6 +25,7 @@ public class StandardActivity<R extends Runnable,S> extends SimpleActivity {
private final DriverAdapter<R,S> adapter;
private final OpSource<R> opsource;
private NBErrorHandler errorHandler;
OpSequence<OpDispenser<R>> sequence;
public StandardActivity(DriverAdapter<R,S> adapter, ActivityDef activityDef) {
super(activityDef);
@ -33,8 +34,8 @@ public class StandardActivity<R extends Runnable,S> extends SimpleActivity {
try {
Function<ParsedCommand, OpDispenser<R>> opmapper = adapter.getOpMapper();
Function<Map<String, Object>, Map<String, Object>> preprocessor = adapter.getPreprocessor();
OpSequence<OpDispenser<R>> seq = createOpSourceFromCommands(opmapper,List.of(preprocessor));
opsource= OpSource.of(seq);
sequence = createOpSourceFromCommands(opmapper,List.of(preprocessor));
opsource= OpSource.of(sequence);
} catch (Exception e) {
if (e instanceof OpConfigError) {
throw e;
@ -44,6 +45,12 @@ public class StandardActivity<R extends Runnable,S> extends SimpleActivity {
}
}
@Override
public void initActivity() {
super.initActivity();
setDefaultsFromOpSequence(sequence);
}
public OpSource<R> getOpSource() {
return opsource;
}