IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-01-11 00:12:04 -06:00
Code Issues Packages Projects Releases Wiki Activity

doc updates

Browse Source
This commit is contained in:
Jonathan Shook 2020-03-04 13:15:16 -06:00
parent cdec63aec7
commit 768d5c676f
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
virtdata-api/src/main/java/io/nosqlbench/virtdata/api/VirtData.java
View File

@ -71,10 +71,11 @@ public class VirtData {
* Instantiate an optional data mapping function if possible.
*
* @param flowSpec The VirtData specifier for the mapping function
* @param config A map of configuration objects
* @param <T> The parameterized return type of the function
* @return An optional function which will be empty if the function could not be resolved.
*/
public static <T> Optional<DataMapper<T>> getOptionalMapper(String flowSpec, Map<String,?> cfg) {
public static <T> Optional<DataMapper<T>> getOptionalMapper(String flowSpec, Map<String,?> config) {
flowSpec = CompatibilityFixups.fixup(flowSpec);
VirtDataDSL.ParseResult parseResult = VirtDataDSL.parse(flowSpec);
if (parseResult.throwable != null) {
@ -82,7 +83,7 @@ public class VirtData {
}
VirtDataFlow flow = parseResult.flow;
VirtDataComposer composer = new VirtDataComposer();
composer.addCustomElements(cfg);
composer.addCustomElements(config);
Optional<ResolvedFunction> resolvedFunction = composer.resolveFunctionFlow(flow);
return resolvedFunction.map(ResolvedFunction::getFunctionObject).map(DataMapperFunctionMapper::map);
}
@ -242,6 +243,7 @@ public class VirtData {
*
* @param flowSpec The VirtData specifier for the mapping function
* @param <T> The parameterized return type of the function
* @param config A map of configuration objects
* @return A data mapping function
* @throws RuntimeException if the function could not be resolved
*/
@ -259,6 +261,7 @@ public class VirtData {
* @param flowSpec The VirtData flow specifier for the function to be returned
* @param clazz The class of the data mapping function return type
* @param <T> The parameterized class of the data mapping return type
* @param config A map of configuration objects
* @return A new data mapping function.
* @throws RuntimeException if the function could not be resolved
*/