Author: jbellis
Date: Wed Sep 22 02:05:22 2010
New Revision: 999725
URL: http://svn.apache.org/viewvc?rev=999725&view=rev
Log:
r/m Clock struct from WordCountSetup. patch by Jeremy Hanna; reviewed by
jbellis for CASSANDRA-1529
Modified:
cassandra/trunk/contrib/word_count/src/WordCountSetup.java
Modified: cassandra/trunk/contrib/word_count/src/WordCountSetup.java
URL:
http://svn.apache.org/viewvc/cassandra/trunk/contrib/word_count/src/WordCountSetup.java?rev=999725&r1=999724&r2=999725&view=diff
==============================================================================
--- cassandra/trunk/contrib/word_count/src/WordCountSetup.java (original)
+++ cassandra/trunk/contrib/word_count/src/WordCountSetup.java Wed Sep 22
02:05:22 2010
@@ -49,13 +49,13 @@ public class WordCountSetup
// text0: no rows
// text1: 1 row, 1 word
- c = new Column("text1".getBytes(), "word1".getBytes(), new
Clock(System.currentTimeMillis()));
+ c = new Column("text1".getBytes(), "word1".getBytes(),
System.currentTimeMillis());
mutationMap = getMutationMap("key0".getBytes(),
WordCount.COLUMN_FAMILY, c);
client.batch_mutate(mutationMap, ConsistencyLevel.ONE);
logger.info("added text1");
// text1: 1 row, 2 word
- c = new Column("text2".getBytes(), "word1 word2".getBytes(), new
Clock(System.currentTimeMillis()));
+ c = new Column("text2".getBytes(), "word1 word2".getBytes(),
System.currentTimeMillis());
mutationMap = getMutationMap("key0".getBytes(),
WordCount.COLUMN_FAMILY, c);
client.batch_mutate(mutationMap, ConsistencyLevel.ONE);
logger.info("added text2");
@@ -64,7 +64,7 @@ public class WordCountSetup
mutationMap = new HashMap<byte[],Map<String,List<Mutation>>>();
for (int i=0; i<1000; i++)
{
- c = new Column("text3".getBytes(), "word1".getBytes(), new
Clock(System.currentTimeMillis()));
+ c = new Column("text3".getBytes(), "word1".getBytes(),
System.currentTimeMillis());
addToMutationMap(mutationMap, ("key" + i).getBytes(),
WordCount.COLUMN_FAMILY, c);
}
client.batch_mutate(mutationMap, ConsistencyLevel.ONE);