Кассандра - Есть ли способ ограничить количество асинхронных запросов?
Я хотел бы знать, есть ли способ ограничить количество запросов, выполняемых одновременно драйвером Java Cassandra?
В настоящее время я выполняю много запросов следующим образом:
...
PreparedStatement stmt = session.prepare("SELECT * FROM users WHERE id = ?");
BoundStatement boundStatement = new BoundStatement(stmt);
List<ResultSetFuture> futures = Lists.newArrayListWithExpectedSize(list.length);
for(String id : list ) {
futures.add(session.executeAsync(boundStatement.bind(id)));
}
for (ListenableFuture<ResultSet> future : futures) {
ResultSet rs = future.get();
... // do some stuff
}
К сожалению, это может привести к NoHostAvailableException.
Спасибо вам.