natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

cassandra-stress support for varint 

patch by sebastian estevez; reviewed by benedict for CASSANDRA-8882
This commit is contained in:
Sebastian Estevez 2015-03-04 16:44:14 +00:00 committed by Benedict Elliott Smith
parent a1e2978f9f
commit 7712e0ef07
3 changed files with 42 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -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)

3
tools/stress/src/org/apache/cassandra/stress/StressProfile.java
View File

@ -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:

39
tools/stress/src/org/apache/cassandra/stress/generate/values/BigIntegers.java Normal file
View File

@ -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());
}
}