spróbować czegoś takiego:
public class Dumper {
private final Cluster cluster;
private final Keyspace keyspace;
public Dumper() {
this.cluster = HFactory.getOrCreateCluster("Name", "hostname");
this.keyspace = HFactory.createKeyspace("Keyspace", cluster, new QuorumAllConsistencyLevelPolicy());
}
public void run() {
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();
// we'll skip this first one, since it is the same as the last one from previous time we executed
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;
}
System.out.println(row);
}
if (rows.getCount() < row_count)
break;
}
}
public static void main(String[] args) {
new Dumper().run();
}
}
tej stronie przez rodziny w kolumnie stron 100 wierszy. Będzie pobierał tylko 10 kolumn dla każdego wiersza (będziesz również chciał wysyłać bardzo długie wiersze).
To jest dla rodziny kolumn z kluczami uuids dla kluczy wierszy, łańcuchów dla nazw kolumn i wartości liczbowych dla długich. Mam nadzieję, że powinno to być oczywiste, jak to zmienić.
Dzięki za odpowiedź. Ale to właśnie zrobiłem. Po prostu ustawę rangeSlicesQuery.setKeys ("", "") i nie ustawiam żadnej liczby wierszy. Zwróciło to wszystkie wiersze z rodziny kolumn. Wygląda na to, że nie trzeba przeglądać kolumn. –
Aby kontynuować z moim poprzednim komentarzem, aby to zrobić, musiałem podać nazwy kolumn. –
Jestem pewien, że Hector nie zaimplementuje stronicowania dla ciebie. Twój kod prawdopodobnie zawiedzie z powodu przekroczenia limitu czasu (lub, co gorsza, spowoduje Cassandra w OOM), gdy zbiór danych stanie się większy, ponieważ zrobienie tego, co sugerujesz, spowoduje, że Cassandra załaduje cały zestaw danych do pamięci RAM. –