cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gdusba...@apache.org
Subject svn commit: r950632 - /cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java
Date Wed, 02 Jun 2010 16:40:31 GMT
Author: gdusbabek
Date: Wed Jun  2 16:40:30 2010
New Revision: 950632

URL: http://svn.apache.org/viewvc?rev=950632&view=rev
Log:
fix non-compiling CBL

Modified:
    cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java

Modified: cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java?rev=950632&r1=950631&r2=950632&view=diff
==============================================================================
--- cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java (original)
+++ cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java Wed Jun  2 16:40:30 2010
@@ -53,6 +53,7 @@ import java.util.List;
 
 import org.apache.cassandra.config.CFMetaData;
 import org.apache.cassandra.config.DatabaseDescriptor;
+import org.apache.cassandra.db.clock.TimestampReconciler;
 import org.apache.cassandra.db.*;
 import org.apache.cassandra.db.filter.QueryPath;
 import org.apache.cassandra.dht.BigIntegerToken;
@@ -234,6 +235,7 @@ public class CassandraBulkLoader {
                                             ClockType.Timestamp,
                                             DatabaseDescriptor.getComparator(Keyspace, CFName),
                                             DatabaseDescriptor.getSubComparator(Keyspace,
CFName),
+                                            new TimestampReconciler(),
                                             CFMetaData.getId(Keyspace, CFName));
         
         for(ColumnFamily cf : ColumnFamiles) {



Mime
View raw message