java - 通过 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;
          }

        }

    }
}