Uses of Interface
org.springframework.data.cassandra.ReactiveResultSet
Package
Description
Spring Data's Cassandra abstraction.
Apache Cassandra core support.
CQL core support.
Provides utility classes for simple
CqlSession
access and various session
implementations.Infrastructure to provide driver observability using Micrometer.
-
Uses of ReactiveResultSet in org.springframework.data.cassandra
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<ReactiveResultSet>
ReactiveSession.execute
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) Executes the provided query.reactor.core.publisher.Mono<ReactiveResultSet>
Executes the provided query.reactor.core.publisher.Mono<ReactiveResultSet>
Executes the provided query using the provided values.reactor.core.publisher.Mono<ReactiveResultSet>
Executes the provided query using the provided named values. -
Uses of ReactiveResultSet in org.springframework.data.cassandra.core
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<ReactiveResultSet>
ReactiveCassandraOperations.execute
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) Execute the given CassandraStatement
.reactor.core.publisher.Mono<ReactiveResultSet>
ReactiveCassandraTemplate.execute
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) -
Uses of ReactiveResultSet in org.springframework.data.cassandra.core.cql
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<ReactiveResultSet>
ReactiveCqlOperations.queryForResultSet
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) Execute a query for a ResultSet, given static CQL.reactor.core.publisher.Mono<ReactiveResultSet>
ReactiveCqlOperations.queryForResultSet
(String cql) Execute a query for a ResultSet, given static CQL.reactor.core.publisher.Mono<ReactiveResultSet>
ReactiveCqlOperations.queryForResultSet
(String cql, Object... args) Query given CQL to create a prepared statement from CQL and a list of arguments to bind to the query, expecting a ResultSet.reactor.core.publisher.Mono<ReactiveResultSet>
ReactiveCqlTemplate.queryForResultSet
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) reactor.core.publisher.Mono<ReactiveResultSet>
ReactiveCqlTemplate.queryForResultSet
(String cql) reactor.core.publisher.Mono<ReactiveResultSet>
ReactiveCqlTemplate.queryForResultSet
(String cql, Object... args) Modifier and TypeMethodDescriptionorg.reactivestreams.Publisher<T>
ReactiveResultSetExtractor.extractData
(ReactiveResultSet resultSet) Implementations must implement this method to process the entireReactiveResultSet
.org.reactivestreams.Publisher<T>
ReactiveRowMapperResultSetExtractor.extractData
(ReactiveResultSet resultSet) -
Uses of ReactiveResultSet in org.springframework.data.cassandra.core.cql.session
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<ReactiveResultSet>
DefaultBridgedReactiveSession.execute
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) reactor.core.publisher.Mono<ReactiveResultSet>
reactor.core.publisher.Mono<ReactiveResultSet>
reactor.core.publisher.Mono<ReactiveResultSet>
-
Uses of ReactiveResultSet in org.springframework.data.cassandra.observability
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<ReactiveResultSet>
ObservableReactiveSession.execute
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) reactor.core.publisher.Mono<ReactiveResultSet>
reactor.core.publisher.Mono<ReactiveResultSet>
reactor.core.publisher.Mono<ReactiveResultSet>