通過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; 
      } 

     } 

    } 
}