Author: ivol37 at gmail.com
Date: Wed Jan 12 16:53:23 2011
New Revision: 610
Log:
Modified:
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java
Modified:
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java
==============================================================================
---
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java
(original)
+++
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java
Wed Jan 12 16:53:23 2011
@@ -47,6 +47,7 @@
import org.apache.cassandra.thrift.ColumnParent;
import org.apache.cassandra.thrift.ConsistencyLevel;
import org.apache.cassandra.thrift.IndexClause;
+import org.apache.cassandra.thrift.IndexExpression;
import org.apache.cassandra.thrift.InvalidRequestException;
import org.apache.cassandra.thrift.KeyRange;
import org.apache.cassandra.thrift.KeySlice;
@@ -269,6 +270,10 @@
public List<String> getRowKeys2(String keyspace, String columnFamilyName)
throws IOException, TimeoutException, UnavailableException {
SlicePredicate p = new SlicePredicate();
IndexClause indexClause = new IndexClause();
+ indexClause.setCount(ROW_LIMIT);
+ indexClause.setStart_key(EMPTY);
+ List<IndexExpression> expressions = new ArrayList<IndexExpression>();
+ indexClause.setExpressions(expressions);
List<Row> rows = StorageProxy.scan(keyspace, columnFamilyName,
indexClause, p, ConsistencyLevel.ALL);
List<String> keys = new ArrayList<String>();
for (Row row : rows) {
