diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/Cities.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/Cities.java new file mode 100644 index 000000000..07dea36b9 --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CitiesByDensity.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CitiesByDensity.java new file mode 100644 index 000000000..f972bd6a8 --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CitiesByPopulation.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CitiesByPopulation.java new file mode 100644 index 000000000..86074ccb5 --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/Counties.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/Counties.java new file mode 100644 index 000000000..5ae1bf427 --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CountiesByDensity.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CountiesByDensity.java new file mode 100644 index 000000000..a717c8acc --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CountiesByPopulation.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CountiesByPopulation.java new file mode 100644 index 000000000..3e17dbbfc --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CountryCodes.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/CountryCodes.java new file mode 100644 index 000000000..0542d0e80 --- /dev/null +++ b/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 { + + @Example("CountryCodes()") + public CountryCodes() { + super("COUNTRY_CODE","n/a","name","countries.csv"); + } + +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateCodes.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateCodes.java new file mode 100644 index 000000000..e43f4574c --- /dev/null +++ b/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 { + + @Example("StateCodes()") + public StateCodes() { + super("state_id","n/a","name","simplemaps/uszips"); + } + +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateCodesByDensity.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateCodesByDensity.java new file mode 100644 index 000000000..096131618 --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateCodesByPopulation.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateCodesByPopulation.java new file mode 100644 index 000000000..b88408131 --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateNames.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateNames.java new file mode 100644 index 000000000..5a0f6ff67 --- /dev/null +++ b/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 { + + @Example("StateNames()") + public StateNames() { + super("state_name","n/a","name","simplemaps/uszips"); + } + +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateNamesByDensity.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateNamesByDensity.java new file mode 100644 index 000000000..4ed10b845 --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateNamesByPopulation.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/StateNamesByPopulation.java new file mode 100644 index 000000000..762a823db --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/TimeZones.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/TimeZones.java new file mode 100644 index 000000000..1b31c89ca --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/TimeZonesByPopulation.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/TimeZonesByPopulation.java new file mode 100644 index 000000000..85a313dc3 --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/ZipCodes.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/ZipCodes.java new file mode 100644 index 000000000..c57cd95b8 --- /dev/null +++ b/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"); + } +} diff --git a/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/ZipCodesByPopulation.java b/virtdata-lib-realer/src/main/java/io/nosqlbench/virtdata/library/realer/ZipCodesByPopulation.java new file mode 100644 index 000000000..2c71764fd --- /dev/null +++ b/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"); + } +}