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);