cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bened...@apache.org
Subject [1/3] cassandra git commit: cassandra-stress support for varint
Date Wed, 04 Mar 2015 16:44:56 GMT
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-2.1 a1e2978f9 -> 7712e0ef0
  refs/heads/trunk 36bd31d05 -> a4221b721


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/cassandra-2.1
Commit: 7712e0ef071bcfd110bd67723589a4bf0e669c82
Parents: a1e2978
Author: Sebastian Estevez <sebastian.estevez@datastax.com>
Authored: Wed Mar 4 16:44:14 2015 +0000
Committer: Benedict Elliott Smith <benedict@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());
+    }
+}


Mime
View raw message