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

Merge pull request #878 from nosqlbench/nosqlbench-875-categories

Browse Source 
nosqlbench-875-categories
This commit is contained in:
Jonathan Shook 2022-12-22 18:03:02 -06:00 committed by GitHub
commit 52d5d10b81
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
76 changed files with 219 additions and 82 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
virtdata-api/src/main/java/io/nosqlbench/virtdata/api/processors/FunctionDocInfoProcessor.java
View File

@ -111,6 +111,8 @@ public class FunctionDocInfoProcessor extends AbstractProcessor {
if (categoryAnnotation!=null) {
Category[] value = categoryAnnotation.value();
enumerator.onCategories(value);
} else {
messenger.printMessage(Diagnostic.Kind.ERROR,"@Categories is a required annotation", classElem);
}
// apply method types

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_int/Add.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongToIntFunction;
@ThreadSafeMapper
@Categories({Category.general})
public class Add implements LongToIntFunction {
private final long addend;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_int/Div.java
View File

@ -15,6 +15,8 @@
*/
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.Description;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
@ -22,6 +24,7 @@ import java.util.function.LongToIntFunction;
@Description("divides the operand by an long and returns the whole part")
@ThreadSafeMapper
@Categories({Category.general})
public class Div implements LongToIntFunction {
private final int divisor;

1
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_int/FixedValue.java
View File

@ -28,7 +28,6 @@ import java.util.function.LongToIntFunction;
*/
@ThreadSafeMapper
@Categories({Category.general})
public class FixedValue implements LongToIntFunction {
private final int fixedValue;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_int/Mul.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongToIntFunction;
@ThreadSafeMapper
@Categories({Category.general})
public class Mul implements LongToIntFunction {
public Mul(int multiplicand) {

40
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_int/Scale.java
View File

@ -1,40 +0,0 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongToIntFunction;
@ThreadSafeMapper
@Deprecated
@Categories({Category.general})
public class Scale implements LongToIntFunction {
private final double scaleFactor;
public Scale(double scaleFactor) {
this.scaleFactor = scaleFactor;
}
@Override
public int applyAsInt(long value) {
return (int) (scaleFactor * (double) value);
}
}

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/Add.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class Add implements LongUnaryOperator {
private final long addend;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/AddCycleRange.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class AddCycleRange implements LongUnaryOperator {
private final CycleRange cycleRange;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/AddHashRange.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class AddHashRange implements LongUnaryOperator {
private final HashRange hashRange;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/Clamp.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
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;
@ -26,6 +28,7 @@ import java.util.function.LongUnaryOperator;
* at most the maximum value.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class Clamp implements LongUnaryOperator {
private final long min;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/CycleRange.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class CycleRange implements LongUnaryOperator {
private final long minValue;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/Div.java
View File

@ -15,6 +15,8 @@
*/
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
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;
@ -24,6 +26,7 @@ import java.util.function.LongUnaryOperator;
* Divide the operand by a fixed value and return the result.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class Div implements LongUnaryOperator {
private final long divisor;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/FixedValue.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class FixedValue implements LongUnaryOperator {
private final long fixedValue;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/HashInterval.java
View File

@ -17,6 +17,8 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.api.errors.BasicError;
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;
@ -33,6 +35,7 @@ import java.util.function.LongUnaryOperator;
* (5,6), or as wide as the relevant data type allows.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class HashInterval implements LongUnaryOperator {
private final long minValue;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/HashRange.java
View File

@ -17,6 +17,8 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.api.errors.BasicError;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongUnaryOperator;
@ -30,6 +32,7 @@ import java.util.function.LongUnaryOperator;
* (5,5), or as wide as the relevant data type allows.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class HashRange implements LongUnaryOperator {
private final long minValue;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/HashRangeScaled.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongUnaryOperator;
@ -25,6 +27,7 @@ import java.util.function.LongUnaryOperator;
* a scale factor, with a default scale factor of 1.0d
*/
@ThreadSafeMapper
@Categories({Category.general})
public class HashRangeScaled implements LongUnaryOperator {
private final double scalefactor;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/Interpolate.java
View File

@ -17,12 +17,15 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
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 java.util.function.LongUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class Interpolate implements LongUnaryOperator {
private final io.nosqlbench.virtdata.library.basics.shared.from_long.to_double.Interpolate basefunc;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/Max.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
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;
@ -25,6 +27,7 @@ import java.util.function.LongUnaryOperator;
* Return the maximum of either the input value or the specified max.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class Max implements LongUnaryOperator {
private final long max;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/Min.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongUnaryOperator;
@ -24,6 +26,7 @@ import java.util.function.LongUnaryOperator;
* Return the minimum of either the input value or the specified minimum.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class Min implements LongUnaryOperator {
private final long min;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/Mod.java
View File

@ -15,6 +15,8 @@
*/
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongUnaryOperator;
@ -23,6 +25,7 @@ import java.util.function.LongUnaryOperator;
* Return the result of modulo division by the specified divisor.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class Mod implements LongUnaryOperator {
private final Long modulo;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/Mul.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongUnaryOperator;
@ -24,6 +26,7 @@ import java.util.function.LongUnaryOperator;
* Return the result of multiplying the specified value with the input.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class Mul implements LongUnaryOperator {
public Mul(long multiplicand) {

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_long/SignedHash.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import io.nosqlbench.virtdata.murmur.Murmur3F;
@ -32,6 +34,7 @@ import java.util.function.LongUnaryOperator;
* as well as negative values.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class SignedHash implements LongUnaryOperator {
// TODO: Bench this against the non-state based TL implementations

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_long/to_string/FixedValue.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.from_long.to_string;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.LongFunction;
@ThreadSafeMapper
@Categories({Category.general})
public class FixedValue implements LongFunction<String> {
private final String value;

5
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/from_uuid/ToBase64String.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.from_uuid;
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;
@ -26,8 +28,9 @@ import java.util.UUID;
import java.util.function.Function;
@ThreadSafeMapper
@Categories(Category.conversion)
public class ToBase64String implements Function<UUID,String> {
private ThreadLocal<Base64.Encoder> tl_encoder = ThreadLocal.withInitial(Base64::getEncoder);
private final ThreadLocal<Base64.Encoder> tl_encoder = ThreadLocal.withInitial(Base64::getEncoder);
@Example({"ToBase64String()","Encode the bits of a UUID into a Base64 String"})
public ToBase64String() {

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/AddCycleRange.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.IntUnaryOperator;
@ -24,6 +26,7 @@ import java.util.function.IntUnaryOperator;
* Adds a cycle range to the input, producing an increasing sawtooth-like output.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class AddCycleRange implements IntUnaryOperator {
private final CycleRange cycleRange;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/AddHashRange.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.IntUnaryOperator;
@ -24,6 +26,7 @@ import java.util.function.IntUnaryOperator;
* Adds a pseudo-random value within the specified range to the input.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class AddHashRange implements IntUnaryOperator {
private final io.nosqlbench.virtdata.library.basics.shared.unary_int.HashRange hashRange;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/Clamp.java
View File

@ -16,12 +16,15 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
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 java.util.function.IntUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class Clamp implements IntUnaryOperator {
private final int min;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/CycleRange.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
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;
@ -25,6 +27,7 @@ import java.util.function.IntUnaryOperator;
* Yields a value within a specified range, which rolls over continuously.
*/
@ThreadSafeMapper
@Categories({Category.general})
public class CycleRange implements IntUnaryOperator {
private final int minValue;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/Div.java
View File

@ -15,6 +15,8 @@
*/
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.Description;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
@ -22,6 +24,7 @@ import java.util.function.IntUnaryOperator;
@Description("divides the operand by an integer and returns the whole part")
@ThreadSafeMapper
@Categories({Category.general})
public class Div implements IntUnaryOperator {
private final int divisor;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/HashInterval.java
View File

@ -17,12 +17,15 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.api.errors.BasicError;
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 java.util.function.IntUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class HashInterval implements IntUnaryOperator {
private final int minValue;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/HashRange.java
View File

@ -17,11 +17,14 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.api.errors.BasicError;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.IntUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class HashRange implements IntUnaryOperator {
private final int minValue;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/HashRangeScaled.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.IntUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class HashRangeScaled implements IntUnaryOperator {
private final Hash hash = new Hash();

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/Max.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.IntUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class Max implements IntUnaryOperator {
private final int max;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/Min.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.IntUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class Min implements IntUnaryOperator {
private final int min;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/Mod.java
View File

@ -15,11 +15,14 @@
*/
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.IntUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class Mod implements IntUnaryOperator {
private final int modulo;

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/Mul.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.IntUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class Mul implements IntUnaryOperator {
public Mul(int addend) {

40
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/Scale.java
View File

@ -1,40 +0,0 @@
/*
* Copyright (c) 2022 nosqlbench
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.IntUnaryOperator;
/**
* Scale the input by the factor provided.
* @deprecated use Mul(...) instead
*/
@ThreadSafeMapper
public class Scale implements IntUnaryOperator {
private final double scaleFactor;
public Scale(double scaleFactor) {
this.scaleFactor = scaleFactor;
}
@Override
public int applyAsInt(int operand) {
return (int) (scaleFactor * (double) operand);
}
}

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_int/SignedHash.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import io.nosqlbench.virtdata.murmur.Murmur3F;
@ -23,6 +25,7 @@ import java.nio.ByteBuffer;
import java.util.function.IntUnaryOperator;
@ThreadSafeMapper
@Categories({Category.general})
public class SignedHash implements IntUnaryOperator {
private final ThreadLocal<Murmur3F> murmur3f_TL = ThreadLocal.withInitial(Murmur3F::new);

3
virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/unary_string/ToString.java
View File

@ -16,6 +16,8 @@
package io.nosqlbench.virtdata.library.basics.shared.unary_string;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import java.util.function.Function;
@ -26,6 +28,7 @@ import java.util.function.Function;
* String.valueOf() to the result.
*/
@ThreadSafeMapper
@Categories({Category.conversion})
public class ToString implements Function<Object,String> {
@Override

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Cauchy.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.CauchyDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Cauchy extends LongToDoubleContinuousCurve {
public Cauchy(double median, double scale, String... mods) {
super(new CauchyDistribution(median, scale), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/ChiSquared.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.ChiSquaredDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class ChiSquared extends LongToDoubleContinuousCurve {
public ChiSquared(double degreesOfFreedom, String... mods) {
super(new ChiSquaredDistribution(degreesOfFreedom), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/ConstantContinuous.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.ConstantContinuousDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class ConstantContinuous extends LongToDoubleContinuousCurve {
public ConstantContinuous(double value, String... mods) {
super(new ConstantContinuousDistribution(value), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Enumerated.java
View File

@ -16,11 +16,14 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
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 org.apache.commons.math4.distribution.EnumeratedRealDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Enumerated extends LongToDoubleContinuousCurve {
@Example({"Enumerated('1 2 3 4 5 6')","a fair 6-sided die"})

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Exponential.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.ExponentialDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Exponential extends LongToDoubleContinuousCurve {
public Exponential(double mean, String... mods) {
super(new ExponentialDistribution(mean), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/F.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.FDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class F extends LongToDoubleContinuousCurve {
public F(double numeratorDegreesOfFreedom, double denominatorDegreesOfFreedom, String... mods) {
super(new FDistribution(numeratorDegreesOfFreedom, denominatorDegreesOfFreedom), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Gamma.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.GammaDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Gamma extends LongToDoubleContinuousCurve {
public Gamma(double shape, double scale, String... mods) {
super(new GammaDistribution(shape, scale), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Gumbel.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.GumbelDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Gumbel extends LongToDoubleContinuousCurve {
public Gumbel(double mu, double beta, String... mods) {
super(new GumbelDistribution(mu, beta), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Laplace.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.LaplaceDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Laplace extends LongToDoubleContinuousCurve {
public Laplace(double mu, double beta, String... mods) {
super(new LaplaceDistribution(mu, beta), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Levy.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.LevyDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Levy extends LongToDoubleContinuousCurve { public Levy(double mu, double c, String... mods) { super(new LevyDistribution(mu,c), mods);
}
}

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/LogNormal.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.LogNormalDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class LogNormal extends LongToDoubleContinuousCurve {
public LogNormal(double scale, double shape, String... mods) {
super(new LogNormalDistribution(scale, shape), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Logistic.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.LogisticDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Logistic extends LongToDoubleContinuousCurve {
public Logistic(double mu, double scale, String... mods) {
super(new LogisticDistribution(mu, scale), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Nakagami.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.NakagamiDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Nakagami extends LongToDoubleContinuousCurve {
public Nakagami(double mu, double omega, String... mods) {
super(new NakagamiDistribution(mu, omega), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Normal.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.NormalDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Normal extends LongToDoubleContinuousCurve {
public Normal(double mean, double sd, String... mods) {
super(new NormalDistribution(mean, sd), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Pareto.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.ParetoDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Pareto extends LongToDoubleContinuousCurve {
public Pareto(double scale, double shape, String... mods) {
super(new ParetoDistribution(scale, shape), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/T.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.TDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class T extends LongToDoubleContinuousCurve {
public T(double degreesOfFreedom, String... mods) {
super(new TDistribution(degreesOfFreedom), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Triangular.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.TriangularDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Triangular extends LongToDoubleContinuousCurve {
public Triangular(double a, double c, double b, String... mods) {
super(new TriangularDistribution(a,c,b), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Uniform.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.UniformContinuousDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Uniform extends LongToDoubleContinuousCurve {
public Uniform(double lower, double upper, String... mods) {
super(new UniformContinuousDistribution(lower, upper), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/continuous/long_double/Weibull.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.continuous.long_double;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.WeibullDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Weibull extends LongToDoubleContinuousCurve {
public Weibull(double alpha, double beta, String... mods) {
super(new WeibullDistribution(alpha, beta), mods);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/int_long/Geometric.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.int_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.GeometricDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Geometric extends IntToLongDiscreteCurve {
public Geometric(double p, String... modslist) {
super(new GeometricDistribution(p), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/int_long/Hypergeometric.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.int_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.HypergeometricDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Hypergeometric extends IntToLongDiscreteCurve {
public Hypergeometric(int populationSize, int numberOfSuccesses, int sampleSize, String... modslist) {
super(new HypergeometricDistribution(populationSize, numberOfSuccesses, sampleSize), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/int_long/Pascal.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.int_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.PascalDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Pascal extends IntToLongDiscreteCurve {
public Pascal(int r, double p, String... modslist) {
super(new PascalDistribution(r, p), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/int_long/Poisson.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.int_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.PoissonDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Poisson extends IntToLongDiscreteCurve {
public Poisson(double p, String... modslist) {
super(new PoissonDistribution(p), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/int_long/Uniform.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.int_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.UniformDiscreteDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Uniform extends IntToLongDiscreteCurve {
public Uniform(int lower, int upper, String... modslist) {
super(new UniformDiscreteDistribution(lower, upper), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/int_long/Zipf.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.int_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.ZipfDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Zipf extends IntToLongDiscreteCurve {
public Zipf(int numberOfElements, double exponent, String... modslist) {
super(new ZipfDistribution(numberOfElements, exponent), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_int/Geometric.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.GeometricDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Geometric extends LongToIntDiscreteCurve {
public Geometric(double p, String... modslist) {
super(new GeometricDistribution(p), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_int/Hypergeometric.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.HypergeometricDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Hypergeometric extends LongToIntDiscreteCurve {
public Hypergeometric(int populationSize, int numberOfSuccesses, int sampleSize, String... modslist) {
super(new HypergeometricDistribution(populationSize, numberOfSuccesses, sampleSize), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_int/Pascal.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.PascalDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Pascal extends LongToIntDiscreteCurve {
public Pascal(int r, double p, String... modslist) {
super(new PascalDistribution(r, p), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_int/Poisson.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.PoissonDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Poisson extends LongToIntDiscreteCurve {
public Poisson(double p, String... modslist) {
super(new PoissonDistribution(p), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_int/Uniform.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.UniformDiscreteDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Uniform extends LongToIntDiscreteCurve {
public Uniform(int lower, int upper, String... modslist) {
super(new UniformDiscreteDistribution(lower, upper), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_int/Zipf.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_int;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.ZipfDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Zipf extends LongToIntDiscreteCurve {
public Zipf(int numberOfElements, double exponent, String... modslist) {
super(new ZipfDistribution(numberOfElements, exponent), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_long/Geometric.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.GeometricDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Geometric extends LongToLongDiscreteCurve {
public Geometric(double p, String... modslist) {
super(new GeometricDistribution(p), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_long/Hypergeometric.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.HypergeometricDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Hypergeometric extends LongToLongDiscreteCurve {
public Hypergeometric(int populationSize, int numberOfSuccesses, int sampleSize, String... modslist) {
super(new HypergeometricDistribution(populationSize, numberOfSuccesses, sampleSize), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_long/Pascal.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.PascalDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Pascal extends LongToLongDiscreteCurve {
public Pascal(int r, double p, String... modslist) {
super(new PascalDistribution(r, p), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_long/Poisson.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.PoissonDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Poisson extends LongToLongDiscreteCurve {
public Poisson(double p, String... modslist) {
super(new PoissonDistribution(p), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_long/Uniform.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.UniformDiscreteDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Uniform extends LongToLongDiscreteCurve {
public Uniform(int lower, int upper, String... modslist) {
super(new UniformDiscreteDistribution(lower, upper), modslist);

3
virtdata-lib-curves4/src/main/java/io/nosqlbench/virtdata/library/curves4/discrete/long_long/Zipf.java
View File

@ -16,10 +16,13 @@
package io.nosqlbench.virtdata.library.curves4.discrete.long_long;
import io.nosqlbench.virtdata.api.annotations.Categories;
import io.nosqlbench.virtdata.api.annotations.Category;
import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
import org.apache.commons.statistics.distribution.ZipfDistribution;
@ThreadSafeMapper
@Categories({Category.distributions})
public class Zipf extends LongToLongDiscreteCurve {
public Zipf(int numberOfElements, double exponent, String... modslist) {
super(new ZipfDistribution(numberOfElements, exponent), modslist);