cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r808271 - /incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java
Date Thu, 27 Aug 2009 03:19:40 GMT
Author: jbellis
Date: Thu Aug 27 03:19:40 2009
New Revision: 808271

URL: http://svn.apache.org/viewvc?rev=808271&view=rev
Log:
better fix for COPP.  patch by jbellis

Modified:
    incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java

Modified: incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java?rev=808271&r1=808270&r2=808271&view=diff
==============================================================================
--- incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java (original)
+++ incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java Thu Aug
27 03:19:40 2009
@@ -29,10 +29,7 @@
 import java.util.concurrent.ExecutionException;
 
 import org.apache.cassandra.db.filter.QueryPath;
-import org.apache.cassandra.dht.Range;
-import org.apache.cassandra.dht.StringToken;
-import org.apache.cassandra.dht.BytesToken;
-import org.apache.cassandra.dht.CollatingOrderPreservingPartitioner;
+import org.apache.cassandra.dht.*;
 import org.apache.cassandra.net.EndPoint;
 import org.apache.cassandra.net.io.StreamContextManager;
 import org.junit.Test;
@@ -59,7 +56,8 @@
         store.forceBlockingFlush();
         List<String> fileList = new ArrayList<String>();
         List<Range> ranges  = new ArrayList<Range>();
-        Range r = new Range(CollatingOrderPreservingPartitioner.MINIMUM, new BytesToken("zzzzzz".getBytes()));
+        IPartitioner partitioner = new CollatingOrderPreservingPartitioner();
+        Range r = new Range(partitioner.getToken("0"), partitioner.getToken("zzzzzzz"));
         ranges.add(r);
 
         boolean result = store.doAntiCompaction(ranges, new EndPoint("127.0.0.1", 9150),
fileList);



Mime
View raw message