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 DriverAdapters to have config injected upon creation

Browse Source
This commit is contained in:
Jonathan Shook 2021-07-22 17:40:16 -05:00
parent b8a3c98aca
commit ffe7c9c530
1 changed files with 11 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
adapters-api/src/main/java/io/nosqlbench/engine/api/activityimpl/uniform/BaseDriverAdapter.java
View File

@ -1,10 +1,7 @@
package io.nosqlbench.engine.api.activityimpl.uniform; package io.nosqlbench.engine.api.activityimpl.uniform;
import io.nosqlbench.engine.api.activityimpl.uniform.fieldmappers.FieldDestructuringMapper; import io.nosqlbench.engine.api.activityimpl.uniform.fieldmappers.FieldDestructuringMapper;
import io.nosqlbench.nb.api.config.standard.ConfigModel; import io.nosqlbench.nb.api.config.standard.*;
import io.nosqlbench.nb.api.config.standard.NBConfigModel;
import io.nosqlbench.nb.api.config.standard.NBConfiguration;
import io.nosqlbench.nb.api.config.standard.NBMapConfigurable;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
@ -14,10 +11,10 @@ import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;
public abstract class BaseDriverAdapter<R extends Runnable,S> public abstract class BaseDriverAdapter<R extends Runnable,S>
implements DriverAdapter<R,S>, NBMapConfigurable { implements DriverAdapter<R,S>, NBConfigurable {
private final DriverSpaceCache<? extends S> spaceCache; private final DriverSpaceCache<? extends S> spaceCache;
private NBConfiguration NBCfgReader; private NBConfiguration cfg;
protected BaseDriverAdapter() { protected BaseDriverAdapter() {
this.spaceCache = new DriverSpaceCache<>(getSpaceInitializer()); this.spaceCache = new DriverSpaceCache<>(getSpaceInitializer());
@ -86,11 +83,6 @@ public abstract class BaseDriverAdapter<R extends Runnable,S>
return spaceCache; return spaceCache;
} }
@Override
public final void applyConfig(Map<String, ?> providedConfig) {
NBConfiguration config = getConfigModel().apply(providedConfig);
}
/** /**
* In order to be provided with config information, it is required * In order to be provided with config information, it is required
* that the driver adapter specify the valid configuration options, * that the driver adapter specify the valid configuration options,
@ -101,7 +93,13 @@ public abstract class BaseDriverAdapter<R extends Runnable,S>
return ConfigModel.of(this.getClass()); return ConfigModel.of(this.getClass());
} }
public NBConfiguration getConfigReader() { public NBConfiguration getConfiguration() {
return NBCfgReader; return cfg;
} }
@Override
public void applyConfig(NBConfiguration cfg) {
this.cfg = cfg;
}
} }