added random key, format cleanup

zznate · Aug 12, 2010 · ec17548 · ec17548
1 parent 428e4a1
commit ec17548
Showing 1 changed file with 11 additions and 13 deletions.
diff --git a/src/main/java/com/vrvm/cassandra/hector/example/FromUsersBatchMutate.java b/src/main/java/com/vrvm/cassandra/hector/example/FromUsersBatchMutate.java
@@ -11,6 +11,7 @@
 import me.prettyprint.cassandra.utils.StringUtils;
 
 import org.apache.cassandra.thrift.Column;
+import org.apache.commons.lang.RandomStringUtils;
 
 /**
  * Uses BatchMutation from a use case off of hector-users
@@ -36,34 +37,31 @@ public static void main(String[] args) throws Exception {
             int counter = 0;
             for (int i = 0; i <= 25000; i++) {
                 for (int j = 0; j < 5; j++) {
-                    Column lang = new
+                    Column lang = new Column(StringUtils.bytes("language_" + j),
-                    Column(StringUtils.bytes("language_" + j),
                             StringUtils.bytes("English"),
                             keyspace.createTimestamp());
-                    batchMutation.addInsertion((counter+"_key"), columnFamilies, lang);
+                    String key = String.format("%d_key_%s", counter, RandomStringUtils.randomAlphanumeric(6));
-                    Column query = new
+                    batchMutation.addInsertion(key, columnFamilies, lang);
-                    Column(StringUtils.bytes("query_" + j),
+                    Column query = new Column(StringUtils.bytes("query_" + j),
                             StringUtils.bytes("search for Auto CAD_" +
                                     i), keyspace.createTimestamp());
-                    batchMutation.addInsertion((counter+"_key"),
+                    batchMutation.addInsertion(key,
                             columnFamilies, query);
                     Column url = new Column(StringUtils.bytes("url_" +
                             j),
                             StringUtils.bytes("www.autodesk.com"),
                             keyspace.createTimestamp());
-                    batchMutation.addInsertion((counter+"_key"),
+                    batchMutation.addInsertion(key,
                             columnFamilies, url);
-                    Column authorCol = new
+                    Column authorCol = new Column(StringUtils.bytes("position_" + j),
-                    Column(StringUtils.bytes("position_" + j),
                             StringUtils.bytes(String.valueOf(i)),
                             keyspace.createTimestamp());
-                    batchMutation.addInsertion((counter+"_key"),
+                    batchMutation.addInsertion(key,
                             columnFamilies, authorCol);
-                    Column userId = new
+                    Column userId = new Column(StringUtils.bytes("userId_" + j),
-                    Column(StringUtils.bytes("userId_" + j),
                             StringUtils.bytes("bandops_" + i),
                             keyspace.createTimestamp());
-                    batchMutation.addInsertion((counter+"_key"),
+                    batchMutation.addInsertion(key,
                             columnFamilies, userId);
                 }