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

        }

    }
}