additional premade binding functions

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/Cities.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a valid city name.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class Cities extends CSVSampler {
+    @Example("Cities()")
+    public Cities() {
+        super("city","n/a","name","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CitiesByDensity.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a city name, weighted by population density.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class CitiesByDensity extends CSVSampler {
+    @Example("CitiesByDensity()")
+    public CitiesByDensity() {
+        super("city","density","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CitiesByPopulation.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a city name, weighted by total population.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class CitiesByPopulation extends CSVSampler {
+    @Example("CitiesByPopulation()")
+    public CitiesByPopulation() {
+        super("city","population","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/Counties.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a valid county name.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class Counties extends CSVSampler {
+    @Example("Counties()")
+    public Counties() {
+        super("city","n/a","name","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CountiesByDensity.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a county name weighted by population density.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class CountiesByDensity extends CSVSampler {
+    @Example("CountiesByDensity()")
+    public CountiesByDensity() {
+        super("county_name","density","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CountiesByPopulation.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a county name weighted by total population.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class CountiesByPopulation extends CSVSampler {
+    @Example("CountiesByPopulation()")
+    public CountiesByPopulation() {
+        super("county_name","population","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CountryCodes.java

@@ -0,0 +1,23 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+import java.util.function.LongFunction;
+
+/**
+ * Return a valid country code.
+ */
+@Categories(Category.premade)
+@ThreadSafeMapper
+public class CountryCodes extends CSVSampler implements LongFunction<String> {
+
+    @Example("CountryCodes()")
+    public CountryCodes() {
+        super("COUNTRY_CODE","n/a","name","countries.csv");
+    }
+
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateCodes.java

@@ -0,0 +1,23 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+import java.util.function.LongFunction;
+
+/**
+ * Return a valid state code. (abbreviation)
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class StateCodes extends CSVSampler implements LongFunction<String> {
+
+    @Example("StateCodes()")
+    public StateCodes() {
+        super("state_id","n/a","name","simplemaps/uszips");
+    }
+
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateCodesByDensity.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a state code (abbreviation), weighted by population density.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class StateCodesByDensity extends CSVSampler {
+    @Example("StateCodesByDensity()")
+    public StateCodesByDensity() {
+        super("state_id","density","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateCodesByPopulation.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a state code (abbreviation), weighted by population.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class StateCodesByPopulation extends CSVSampler {
+    @Example("StateCodesByPopulation()")
+    public StateCodesByPopulation() {
+        super("state_id","population","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateNames.java

@@ -0,0 +1,23 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+import java.util.function.LongFunction;
+
+/**
+ * Return a valid state name.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class StateNames extends CSVSampler implements LongFunction<String> {
+
+    @Example("StateNames()")
+    public StateNames() {
+        super("state_name","n/a","name","simplemaps/uszips");
+    }
+
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateNamesByDensity.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a state name, weighted by population density.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class StateNamesByDensity extends CSVSampler {
+    @Example("StateNamesByDensity()")
+    public StateNamesByDensity() {
+        super("state_name","density","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateNamesByPopulation.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a state name, weighted by total population.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class StateNamesByPopulation extends CSVSampler {
+    @Example("StateNamesByPopulation()")
+    public StateNamesByPopulation() {
+        super("state_name","population","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/TimeZones.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a state name, weighted by population density.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class TimeZones extends CSVSampler {
+    @Example("Timezones()")
+    public TimeZones() {
+        super("timezone","n/a","name","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/TimeZonesByPopulation.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a state name, weighted by population.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class TimeZonesByPopulation extends CSVSampler {
+    @Example("TimezonesByPopulation()")
+    public TimeZonesByPopulation() {
+        super("timezone","population","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/ZipCodes.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a valid zip code.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class ZipCodes extends CSVSampler {
+    @Example("ZipCodes()")
+    public ZipCodes() {
+        super("zip","n/a","name","simplemaps/uszips");
+    }
+}

virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/ZipCodesByPopulation.java

@@ -0,0 +1,19 @@
+package io.nosqlbench.virtdata.library.realer;
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.Example;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+import io.nosqlbench.virtdata.library.basics.shared.distributions.CSVSampler;
+
+/**
+ * Return a zip code, weighted by population.
+ */
+@ThreadSafeMapper
+@Categories(Category.premade)
+public class ZipCodesByPopulation extends CSVSampler {
+    @Example("ZipCodesByPopulation()")
+    public ZipCodesByPopulation() {
+        super("zip","population","simplemaps/uszips");
+    }
+}