natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix unit test. patch by jbellis for CASSANDRA-242 

git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@808268 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jonathan Ellis 2009-08-27 03:13:50 +00:00
parent 021ab75a5f
commit eb6d11d549
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
test/unit/org/apache/cassandra/db/BootstrapTest.java
View File

@ -31,6 +31,8 @@ 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.net.EndPoint;
import org.apache.cassandra.net.io.StreamContextManager;
import org.junit.Test;
@ -45,7 +47,6 @@ public class BootstrapTest
{
Table table = Table.open("Keyspace1");
ColumnFamilyStore store = table.getColumnFamilyStore(columnFamilyName);
for (int j = 0; j < insertsPerTable; j++)
{
@ -58,7 +59,7 @@ public class BootstrapTest
store.forceBlockingFlush();
List<String> fileList = new ArrayList<String>();
List<Range> ranges = new ArrayList<Range>();
Range r = new Range(new StringToken("0"), new StringToken("zzzzzz"));
Range r = new Range(CollatingOrderPreservingPartitioner.MINIMUM, new BytesToken("zzzzzz".getBytes()));
ranges.add(r);
boolean result = store.doAntiCompaction(ranges, new EndPoint("127.0.0.1", 9150), fileList);