adding tenfields activities and RandomStringRangeGenerator

Author: jshook

src/main/java/com/metawiring/load/generators/CycleNumberStringGenerator.java

@@ -0,0 +1,46 @@
+/*
+ *
+ *       Copyright 2015 Jonathan Shook
+ *
+ *   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 com.metawiring.load.generators;
+
+import com.metawiring.load.generator.FastForwardableGenerator;
+import com.metawiring.load.generator.ThreadsafeGenerator;
+import org.joda.time.format.DateTimeFormatter;
+
+import java.util.concurrent.atomic.AtomicLong;
+
+
+public class CycleNumberStringGenerator implements FastForwardableGenerator<String>,ThreadsafeGenerator {
+
+    private AtomicLong seq = new AtomicLong(0l);
+    private DateTimeFormatter formatter;
+
+    public CycleNumberStringGenerator() {
+    }
+
+    @Override
+    public String get() {
+        long outval = seq.incrementAndGet();
+        return String.valueOf(outval);
+    }
+
+    @Override
+    public void fastForward(long fastForwardTo) {
+        seq = new AtomicLong(fastForwardTo);
+    }
+}

src/main/java/com/metawiring/load/generators/RandomStringRangeGenerator.java

@@ -0,0 +1,51 @@
+/*
+ *
+ *       Copyright 2015 Jonathan Shook
+ *
+ *   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 com.metawiring.load.generators;
+
+import com.metawiring.load.generator.Generator;
+import org.apache.commons.math3.random.MersenneTwister;
+
+public class RandomStringRangeGenerator implements Generator<String> {
+    private MersenneTwister theTwister = new MersenneTwister(System.nanoTime());
+    private long min;
+    private long max;
+    private long length;
+
+    public RandomStringRangeGenerator(long min, long max) {
+        this.min = min;
+        this.max = max;
+        this.length = max - min;
+    }
+
+    public RandomStringRangeGenerator(String min, String max) {
+        this(Long.valueOf(min), Long.valueOf(max));
+    }
+
+    @Override
+    public String get() {
+        long value = Math.abs(theTwister.nextLong());
+        value %= length;
+        value += min;
+        return String.valueOf(value);
+    }
+
+    public String toString() {
+        return getClass().getSimpleName() + ":" + min + ":" + max;
+    }
+}

src/main/resources/activities/read-tenfields-random.yaml

@@ -0,0 +1,7 @@
+dml:
+ - name: read-tenfields-random
+   cql: |
+     select * from <<KEYSPACE>>.<<TABLE>>_tenfields
+     where key=?
+   bindings:
+     key: RandomStringRangeGenerator:1:50000000

src/main/resources/activities/read-tenfields-seq.yaml

@@ -0,0 +1,7 @@
+dml:
+ - name: read-tenfields-random
+   cql: |
+     select * from <<KEYSPACE>>.<<TABLE>>_tenfields
+     where key='?'
+   bindings:
+     key: CycleNumberStringGenerator

src/main/resources/activities/write-tenfields-random.yaml

@@ -0,0 +1,40 @@
+ddl:
+- name: create-keyspace
+  cql: |
+    create keyspace if not exists <<KEYSPACE>> WITH replication =
+    {'class': 'SimpleStrategy', 'replication_factor': <<RF>>} and durable_writes = true;
+- name: create-tenfields-table
+  cql: |
+    create table if not exists <<KEYSPACE>>.<<TABLE>>_tenfields (
+    key text primary key,
+    c0 text,
+    c1 text,
+    c2 text,
+    c3 text,
+    c4 text,
+    c5 text,
+    c6 text,
+    c7 text,
+    c8 text,
+    c9 text,
+    );
+
+dml:
+ - name: write-tenfields-random
+   cql: |
+     insert into <<KEYSPACE>>.<<TABLE>>_tenfields (key, c0, c1, c2, c3, c4, c5, c6, c7, c8, c9)
+     values (<<key>>,<<c0>>,<<c1>>,<<c2>>,<<c3>>,<<c4>>,<<c5>>,<<c6>>,<<c7>>,<<c8>>,<<c9>>);
+   bindings:
+     key: RandomStringRangeGenerator:1:50000000
+     c0: LoremExtractGenerator:1000:1000
+     c1: LoremExtractGenerator:1000:1000
+     c2: LoremExtractGenerator:1000:1000
+     c3: LoremExtractGenerator:1000:1000
+     c4: LoremExtractGenerator:1000:1000
+     c5: LoremExtractGenerator:1000:1000
+     c6: LoremExtractGenerator:1000:1000
+     c7: LoremExtractGenerator:1000:1000
+     c8: LoremExtractGenerator:1000:1000
+     c9: LoremExtractGenerator:1000:1000
+
+

src/main/resources/activities/write-tenfields-seq.yaml

@@ -0,0 +1,40 @@
+ddl:
+- name: create-keyspace
+  cql: |
+    create keyspace if not exists <<KEYSPACE>> WITH replication =
+    {'class': 'SimpleStrategy', 'replication_factor': <<RF>>} and durable_writes = true;
+- name: create-tenfields-table
+  cql: |
+    create table if not exists <<KEYSPACE>>.<<TABLE>>_tenfields (
+    key text primary key,
+    c0 text,
+    c1 text,
+    c2 text,
+    c3 text,
+    c4 text,
+    c5 text,
+    c6 text,
+    c7 text,
+    c8 text,
+    c9 text,
+    );
+
+dml:
+ - name: write-tenfields-seq
+   cql: |
+     insert into <<KEYSPACE>>.<<TABLE>>_tenfields (key, c0, c1, c2, c3, c4, c5, c6, c7, c8, c9)
+     values (<<key>>,<<c0>>,<<c1>>,<<c2>>,<<c3>>,<<c4>>,<<c5>>,<<c6>>,<<c7>>,<<c8>>,<<c9>>);
+   bindings:
+     key: CycleNumberStringGenerator
+     c0: LoremExtractGenerator:1000:1000
+     c1: LoremExtractGenerator:1000:1000
+     c2: LoremExtractGenerator:1000:1000
+     c3: LoremExtractGenerator:1000:1000
+     c4: LoremExtractGenerator:1000:1000
+     c5: LoremExtractGenerator:1000:1000
+     c6: LoremExtractGenerator:1000:1000
+     c7: LoremExtractGenerator:1000:1000
+     c8: LoremExtractGenerator:1000:1000
+     c9: LoremExtractGenerator:1000:1000
+
+