通过hector API在cassandra中寻呼用户定义的查询

Question

是否有可能通过用户定义的查询的hector API在cassandra中实现分页？

如果是，如何？

Answer 1

我已经添加了一个基本的方法，其余的东西你必须处理。在这里，你可以看到我们已经将页面大小定义为100行，每行有10列。现在在第一次迭代之后，你必须存储一些如何存储最后的键值，这将是迭代的起点。

int row_count = 100; 

    RangeSlicesQuery<UUID, String, Long> rangeSlicesQuery = HFactory 
     .createRangeSlicesQuery(keyspace, UUIDSerializer.get(), StringSerializer.get(), LongSerializer.get()) 
     .setColumnFamily("Column Family") 
     .setRange(null, null, false, 10) 
     .setRowCount(row_count); 

    UUID last_key = null; 

    while (true) { 
     rangeSlicesQuery.setKeys(last_key, null); 
     System.out.println(" > " + last_key); 

     QueryResult<OrderedRows<UUID, String, Long>> result = rangeSlicesQuery.execute(); 
     OrderedRows<UUID, String, Long> rows = result.get(); 
     Iterator<Row<UUID, String, Long>> rowsIterator = rows.iterator(); 

     if (last_key != null && rowsIterator != null) rowsIterator.next(); 

     while (rowsIterator.hasNext()) { 
      Row<UUID, String, Long> row = rowsIterator.next(); 
      last_key = row.getKey(); 

      if (row.getColumnSlice().getColumns().isEmpty()) { 
      continue; 
      } 

     } 

    } 
}