From a97be906ffb4698e43310a241ab0e2b06c62dbaa Mon Sep 17 00:00:00 2001 From: Eric Evans Date: Wed, 7 Dec 2011 16:36:35 +0000 Subject: [PATCH] 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 --- .../cassandra/stress/operations/CqlInserter.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/tools/stress/src/org/apache/cassandra/stress/operations/CqlInserter.java b/tools/stress/src/org/apache/cassandra/stress/operations/CqlInserter.java index 264f4b114a..57c74198ea 100644 --- a/tools/stress/src/org/apache/cassandra/stress/operations/CqlInserter.java +++ b/tools/stress/src/org/apache/cassandra/stress/operations/CqlInserter.java @@ -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);