在Cassandra 4.X中，我可以用什么用作替代结果？

Question

我必须将Cassandra升级到4.x。 这是先前用Cassandra 3.5编写的代码

 protected <T> Stream<T> getAll(Stream<Statement> statements, Mapper<T> mapper) {
        List<ResultSetFuture> futures = statements
                .peek(p -> cassandraReads.inc())
                .map(s -> session.session().executeAsync(s))
                .collect(Collectors.toList());

        return futures.stream()
                .map(ResultSetFuture::getUninterruptibly)
                .map(mapper::map)
                .flatMap(r -> StreamSupport.stream(r.spliterator(), false));
    }

，我做了一些更改...

 List<CompletionStage<AsyncResultSet>> futures = statements
                .peek(p -> cassandraReads.inc())
                .map(s -> session.getSession().executeAsync(s))
                .collect(Collectors.toList());

但是我应该用什么来代替.map（resultsetFuture :: getunressruption），因为它已被删除。 由于我是卡桑德拉（Cassandra）和异步编程的新手，因此将不胜感激。

Answer 1

由于您已经在代码中混合异步并阻止了调用，因此我建议您完全阻止并使用session.execute而不是session.executeasync。这将使事情变得更加容易。然后，您可以按照以下方式重写代码：

protected <T> Stream<T> getAll(Stream<Statement<?>> statements, Mapper<T> mapper) {
  return statements
      .peek(p -> cassandraReads.inc())
      .map(s -> session.execute(s))
      .flatMap(rs -> StreamSupport.stream(rs.spliterator(), false))
      .map(mapper::map);
}

注意：我正在稍微更改您的mapper接口，我假设它将是：（

public interface Mapper<T> {
  T map(Row row);
}

您实际上可以替换此mapper function＆lt; row，t＆gt; btw。）

除此之外，如埃里克·拉米雷斯（Erick Ramirez）所说，请查看此页面了解如何使用驱动程序4.x编写正确的async代码。

Answer 2

异步编程的API实际上不是由您连接到的Cassandra群集的版本确定的。重要的是您正在使用的Java驱动程序的版本。

如果您仍在使用Java驱动程序3.X，则您的代码应在大部分时间继续工作，直到Java驱动程序3.11。参见 asynchronous在Java驱动程序中的编程3.11 。

直到您升级到Java驱动程序4.x，您才会遇到破坏更改，因为V4.X与Java驱动程序的早期版本不兼容（请参见升级指南有关详细信息）。

如果您升级到Java驱动程序4.x，则可以找到在此处进行异步编程的工作示例。干杯!