cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From eev...@apache.org
Subject svn commit: r948964 - in /cassandra/trunk/contrib: client_only/ClientOnlyExample.java javautils/src/test/java/org/apache/cassandra/contrib/utils/service/CassandraServiceTest.java
Date Thu, 27 May 2010 19:55:10 GMT
Author: eevans
Date: Thu May 27 19:55:10 2010
New Revision: 948964

URL: http://svn.apache.org/viewvc?rev=948964&view=rev
Log:
update contrib/ code for new Column clock

Patch by eevans

Modified:
    cassandra/trunk/contrib/client_only/ClientOnlyExample.java
    cassandra/trunk/contrib/javautils/src/test/java/org/apache/cassandra/contrib/utils/service/CassandraServiceTest.java

Modified: cassandra/trunk/contrib/client_only/ClientOnlyExample.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/contrib/client_only/ClientOnlyExample.java?rev=948964&r1=948963&r2=948964&view=diff
==============================================================================
--- cassandra/trunk/contrib/client_only/ClientOnlyExample.java (original)
+++ cassandra/trunk/contrib/client_only/ClientOnlyExample.java Thu May 27 19:55:10 2010
@@ -53,7 +53,7 @@ public class ClientOnlyExample
         {
             RowMutation change = new RowMutation("Keyspace1", ("key" + i).getBytes());
             ColumnPath cp = new ColumnPath("Standard1").setColumn(("colb").getBytes());
-            change.add(new QueryPath(cp), ("value" + i).getBytes(), 0);
+            change.add(new QueryPath(cp), ("value" + i).getBytes(), new TimestampClock(0));
 
             // don't call change.apply().  The reason is that is makes a static call into
Table, which will perform
             // local storage initialization, which creates local directories.

Modified: cassandra/trunk/contrib/javautils/src/test/java/org/apache/cassandra/contrib/utils/service/CassandraServiceTest.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/contrib/javautils/src/test/java/org/apache/cassandra/contrib/utils/service/CassandraServiceTest.java?rev=948964&r1=948963&r2=948964&view=diff
==============================================================================
--- cassandra/trunk/contrib/javautils/src/test/java/org/apache/cassandra/contrib/utils/service/CassandraServiceTest.java
(original)
+++ cassandra/trunk/contrib/javautils/src/test/java/org/apache/cassandra/contrib/utils/service/CassandraServiceTest.java
Thu May 27 19:55:10 2010
@@ -29,6 +29,7 @@ import org.apache.cassandra.service.Embe
 import org.apache.cassandra.thrift.AuthenticationException;
 import org.apache.cassandra.thrift.AuthorizationException;
 import org.apache.cassandra.thrift.Cassandra;
+import org.apache.cassandra.thrift.Clock;
 import org.apache.cassandra.thrift.Column;
 import org.apache.cassandra.thrift.ColumnOrSuperColumn;
 import org.apache.cassandra.thrift.ColumnParent;
@@ -95,7 +96,7 @@ public class CassandraServiceTest {
 
         // insert
         ColumnParent colParent = new ColumnParent("Standard1");
-        Column column = new Column("name".getBytes("utf-8"), "Ran".getBytes("UTF-8"), timestamp);
+        Column column = new Column("name".getBytes("utf-8"), "Ran".getBytes("UTF-8"), new
Clock(timestamp));
         
         client.insert(key_user_id.getBytes(), colParent, column, ConsistencyLevel.ONE);
 



Mime
View raw message