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

allow injecting ActivityDef into DriverAdapter

Browse Source
This commit is contained in:
Jonathan Shook 2021-07-08 11:48:57 -05:00
parent ff2e058a93
commit 4f1df146bc
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
engine-api/src/main/java/io/nosqlbench/engine/api/activityimpl/uniform/ActivityDefAware.java Normal file
View File

@ -0,0 +1,7 @@
package io.nosqlbench.engine.api.activityimpl.uniform;
import io.nosqlbench.engine.api.activityimpl.ActivityDef;
public interface ActivityDefAware {
void setActivityDef(ActivityDef activiytDef);
}

2
engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/ScenarioController.java
View File

@ -315,7 +315,7 @@ public class ScenarioController {
Optional<DriverAdapter> oda = StandardActivityType.FINDER.getOptionally(activityTypeName); Optional<DriverAdapter> oda = StandardActivityType.FINDER.getOptionally(activityTypeName);
if (oda.isPresent()) { if (oda.isPresent()) {
DriverAdapter driverAdapter = oda.get(); DriverAdapter driverAdapter = oda.get();
activityType = new StandardActivityType<>(driverAdapter); activityType = new StandardActivityType<>(driverAdapter,activityDef);
} else { } else {
throw new RuntimeException("Found neither ActivityType named '" + activityTypeName + "' nor DriverAdapter named '" + activityTypeName + "'."); throw new RuntimeException("Found neither ActivityType named '" + activityTypeName + "' nor DriverAdapter named '" + activityTypeName + "'.");
} }