Uses of Interface
org.springframework.data.cassandra.core.cql.ReactiveResultSetExtractor
Packages that use ReactiveResultSetExtractor
-
Uses of ReactiveResultSetExtractor in org.springframework.data.cassandra.core.cql
Classes in org.springframework.data.cassandra.core.cql that implement ReactiveResultSetExtractorModifier and TypeClassDescriptionclass
Adapter implementation of theReactiveResultSetExtractor
interface that delegates to aRowMapper
which is supposed to create an object for each row.Methods in org.springframework.data.cassandra.core.cql with parameters of type ReactiveResultSetExtractorModifier and TypeMethodDescription<T> reactor.core.publisher.Flux<T>
ReactiveCqlOperations.query
(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ReactiveResultSetExtractor<T> rse) Execute a query given static CQL, reading theReactiveResultSet
with aReactiveResultSetExtractor
.<T> reactor.core.publisher.Flux<T>
ReactiveCqlOperations.query
(String cql, PreparedStatementBinder psb, ReactiveResultSetExtractor<T> rse) Query using a prepared statement, reading theReactiveResultSet
with aReactiveResultSetExtractor
.<T> reactor.core.publisher.Flux<T>
ReactiveCqlOperations.query
(String cql, ReactiveResultSetExtractor<T> rse) Execute a query given static CQL, reading theReactiveResultSet
with aReactiveResultSetExtractor
.<T> reactor.core.publisher.Flux<T>
ReactiveCqlOperations.query
(String cql, ReactiveResultSetExtractor<T> rse, Object... args) Query given CQL to create a prepared statement from CQL and a list of arguments to bind to the query, reading theReactiveResultSet
with aReactiveResultSetExtractor
.<T> reactor.core.publisher.Flux<T>
ReactiveCqlOperations.query
(ReactivePreparedStatementCreator psc, PreparedStatementBinder psb, ReactiveResultSetExtractor<T> rse) Query using a prepared statement and aPreparedStatementBinder
implementation that knows how to bind values to the query, reading theReactiveResultSet
with aResultSetExtractor
.<T> reactor.core.publisher.Flux<T>
ReactiveCqlOperations.query
(ReactivePreparedStatementCreator psc, ReactiveResultSetExtractor<T> rse) Query using a prepared statement, reading theReactiveResultSet
with aReactiveResultSetExtractor
.<T> reactor.core.publisher.Flux<T>
ReactiveCqlTemplate.query
(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ReactiveResultSetExtractor<T> rse) <T> reactor.core.publisher.Flux<T>
ReactiveCqlTemplate.query
(String cql, PreparedStatementBinder psb, ReactiveResultSetExtractor<T> rse) <T> reactor.core.publisher.Flux<T>
ReactiveCqlTemplate.query
(String cql, ReactiveResultSetExtractor<T> resultSetExtractor) <T> reactor.core.publisher.Flux<T>
ReactiveCqlTemplate.query
(String cql, ReactiveResultSetExtractor<T> rse, Object... args) <T> reactor.core.publisher.Flux<T>
ReactiveCqlTemplate.query
(ReactivePreparedStatementCreator psc, PreparedStatementBinder preparedStatementBinder, ReactiveResultSetExtractor<T> rse) Query using a prepared statement, reading theReactiveResultSet
with aReactiveResultSetExtractor
.<T> reactor.core.publisher.Flux<T>
ReactiveCqlTemplate.query
(ReactivePreparedStatementCreator psc, ReactiveResultSetExtractor<T> rse)