如何使用 astyanax 从 cassandra CF 读取所有 1000 行

Question

我们有一个只有大约 1000 行的 CF。 astyanax 有没有办法读取所有 1000 行？ thrift 甚至支持吗？

谢谢， 院长

Answer 1

您可以使用 thrift 调用 get_range_slices 读取所有行。请注意，它以标记顺序返回行，而不是键顺序。因此，可以读取所有行，但不能跨行键执行范围。

您可以通过 getAllRows() 在 Astyanax 中使用它。这是一些示例代码（从https://github.com/Netflix/astyanax/wiki/Reading-Data#iterate-all-rows-in-a-column-family 的文档中复制）

Rows<String, String>> rows;
try {
    rows = keyspace.prepareQuery("ColumnFamilyName")
        .getAllRows()
        .setBlockSize(10)
        .withColumnRange(new RangeBuilder().setMaxSize(10).build())
        .setExceptionCallback(new ExceptionCallback() {
             @Override
             public boolean onException(ConnectionException e) {
                 try {
                     Thread.sleep(1000);
                 } catch (InterruptedException e1) {
                 }
                 return true;
             }})
        .execute().getResult();
} catch (ConnectionException e) {
}

// This will never throw an exception
for (Row<String, String> row : rows.getResult()) {
    LOG.info("ROW: " + row.getKey() + " " + row.getColumns().size());
}

这将返回每行的前 10 列，以 10 行为一组。增加传递给 RangeBuilder().setMaxSize 的数字以获取更多（或更少）列。