mirror of
https://github.com/nosqlbench/nosqlbench.git
synced 2025-02-25 18:55:28 -06:00
provide summary of generated bindings in cqlgen
This commit is contained in:
@@ -21,10 +21,7 @@ import io.nosqlbench.cqlgen.model.CqlColumnBase;
|
|||||||
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.LogManager;
|
||||||
import org.apache.logging.log4j.Logger;
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
import java.util.LinkedHashMap;
|
import java.util.*;
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Optional;
|
|
||||||
|
|
||||||
public class BindingsAccumulator {
|
public class BindingsAccumulator {
|
||||||
private final static Logger logger = LogManager.getLogger("CQL-GENERATOR");
|
private final static Logger logger = LogManager.getLogger("CQL-GENERATOR");
|
||||||
@@ -111,6 +108,11 @@ public class BindingsAccumulator {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public Map<String, String> getAccumulatedBindings() {
|
public Map<String, String> getAccumulatedBindings() {
|
||||||
|
Map<String,Set<String>> inverted = new HashMap<>();
|
||||||
|
accumulated.forEach((k,v) -> {
|
||||||
|
inverted.computeIfAbsent(v,def -> new HashSet<>()).add(k);
|
||||||
|
});
|
||||||
|
logger.info("computed " + accumulated.size() + " raw bindings, consisting of " + inverted.size() + " unique definitions.");
|
||||||
return accumulated;
|
return accumulated;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user