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

Update to support TimeUUIDType (CASSANDRA-3541) 

Patch by eevans; reviewed by Pavel Yaskevich for CASSANDRA-2268


git-svn-id: https://svn.apache.org/repos/asf/cassandra/trunk@1211522 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Eric Evans 2011-12-07 16:36:35 +00:00
parent c0adddd077
commit a97be906ff
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tools/stress/src/org/apache/cassandra/stress/operations/CqlInserter.java
View File

@ -30,6 +30,7 @@ import org.apache.cassandra.stress.Session;
import org.apache.cassandra.stress.util.Operation;
import org.apache.cassandra.thrift.Cassandra;
import org.apache.cassandra.thrift.Compression;
import org.apache.cassandra.utils.UUIDGen;
public class CqlInserter extends Operation
{
@ -55,8 +56,15 @@ public class CqlInserter extends Operation
{
if (i > 0)
query.append(',');
query.append('C').append(i).append('=');
query.append(getQuotedCqlBlob(values.get(i % values.size()).array()));
// Column name
if (session.timeUUIDComparator)
query.append(UUIDGen.makeType1UUIDFromHost(Session.getLocalAddress()).toString());
else
query.append('C').append(i);
// Column value
query.append('=').append(getQuotedCqlBlob(values.get(i % values.size()).array()));
}
String key = String.format("%0" + session.getTotalKeysLength() + "d", index);