Spring 数据 Cassandra 查询 DSL RxJava2
Spring Data Cassandra Query DSL RxJava2
所以我正在使用 Spring Data Cassandra 和 RxJava，我正在寻找一种使用 RxJava Observable 进行自定义查询构建的方法（在我的情况下，find..by 抽象使用起来太复杂了）并且我正计划使用 QueryDSL（方法 findAll(Predicate)，但它不启用异步 :/)
到目前为止，我最好的办法是使用 AsyncCassandraTemplate 构建一个 Query 并将其 return 作为 ListenableFuture，以便它可以映射到一个 Observable 并与 RxJava 的 Observable 一起使用。还有其他办法吗？
Apache Cassandra 不支持 QueryDsl Spring 数据。您可以将 Query objects to create queries and ReactiveCassandraTemplate 用于响应式 API 用法：
Mono<Person> person = cassandraTemplate.selectOneById(query(where("age").is(33)), Person.class);
Maybe<Person> maybe = Flowable.fromPublisher(person).firstElement();
所以我正在使用 Spring Data Cassandra 和 RxJava，我正在寻找一种使用 RxJava Observable 进行自定义查询构建的方法（在我的情况下，find..by 抽象使用起来太复杂了）并且我正计划使用 QueryDSL（方法 findAll(Predicate)，但它不启用异步 :/)
到目前为止，我最好的办法是使用 AsyncCassandraTemplate 构建一个 Query 并将其 return 作为 ListenableFuture，以便它可以映射到一个 Observable 并与 RxJava 的 Observable 一起使用。还有其他办法吗？
Apache Cassandra 不支持 QueryDsl Spring 数据。您可以将 Query objects to create queries and ReactiveCassandraTemplate 用于响应式 API 用法：
Mono<Person> person = cassandraTemplate.selectOneById(query(where("age").is(33)), Person.class);
Maybe<Person> maybe = Flowable.fromPublisher(person).firstElement();