You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by be...@apache.org on 2015/03/04 17:44:57 UTC
[2/3] cassandra git commit: cassandra-stress support for varint
cassandra-stress support for varint
patch by sebastian estevez; reviewed by benedict for CASSANDRA-8882
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/7712e0ef
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/7712e0ef
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/7712e0ef
Branch: refs/heads/trunk
Commit: 7712e0ef071bcfd110bd67723589a4bf0e669c82
Parents: a1e2978
Author: Sebastian Estevez <se...@datastax.com>
Authored: Wed Mar 4 16:44:14 2015 +0000
Committer: Benedict Elliott Smith <be...@apache.org>
Committed: Wed Mar 4 16:44:14 2015 +0000
----------------------------------------------------------------------
CHANGES.txt | 1 +
.../apache/cassandra/stress/StressProfile.java | 3 +-
.../stress/generate/values/BigIntegers.java | 39 ++++++++++++++++++++
3 files changed, 42 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/7712e0ef/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 52f33b3..137c0f1 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -29,6 +29,7 @@
each IndexSummary opened from it (CASSANDRA-8757)
* markCompacting only succeeds if the exact SSTableReader instances being
marked are in the live set (CASSANDRA-8689)
+ * cassandra-stress support for varint (CASSANDRA-8882)
Merged from 2.0:
* Add offline tool to relevel sstables (CASSANDRA-8301)
* Preserve stream ID for more protocol errors (CASSANDRA-8848)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/7712e0ef/tools/stress/src/org/apache/cassandra/stress/StressProfile.java
----------------------------------------------------------------------
diff --git a/tools/stress/src/org/apache/cassandra/stress/StressProfile.java b/tools/stress/src/org/apache/cassandra/stress/StressProfile.java
index 1517fcb..687b3ae 100644
--- a/tools/stress/src/org/apache/cassandra/stress/StressProfile.java
+++ b/tools/stress/src/org/apache/cassandra/stress/StressProfile.java
@@ -481,8 +481,9 @@ public class StressProfile implements Serializable
case INET:
return new Inets(name, config);
case INT:
- case VARINT:
return new Integers(name, config);
+ case VARINT:
+ return new BigIntegers(name, config);
case TIMESTAMP:
return new Dates(name, config);
case UUID:
http://git-wip-us.apache.org/repos/asf/cassandra/blob/7712e0ef/tools/stress/src/org/apache/cassandra/stress/generate/values/BigIntegers.java
----------------------------------------------------------------------
diff --git a/tools/stress/src/org/apache/cassandra/stress/generate/values/BigIntegers.java b/tools/stress/src/org/apache/cassandra/stress/generate/values/BigIntegers.java
new file mode 100644
index 0000000..84a4c8f
--- /dev/null
+++ b/tools/stress/src/org/apache/cassandra/stress/generate/values/BigIntegers.java
@@ -0,0 +1,39 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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 org.apache.cassandra.stress.generate.values;
+
+import org.apache.cassandra.db.marshal.IntegerType;
+
+import java.math.BigInteger;
+
+public class BigIntegers extends Generator<BigInteger>
+{
+ public BigIntegers(String name, GeneratorConfig config)
+ {
+ super(IntegerType.instance, config, name, BigInteger.class);
+ }
+
+ @Override
+ public BigInteger generate()
+ {
+ return BigInteger.valueOf(identityDistribution.next());
+ }
+}