Package | Description |
---|---|
org.springframework.data.cassandra.core.cql |
CQL core support.
|
Modifier and Type | Class and Description |
---|---|
class |
ReactiveRowMapperResultSetExtractor<T>
Adapter implementation of the
ReactiveResultSetExtractor interface that delegates to a RowMapper
which is supposed to create an object for each row. |
Modifier and Type | Method and Description |
---|---|
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(ReactivePreparedStatementCreator psc,
PreparedStatementBinder preparedStatementBinder,
ReactiveResultSetExtractor<T> rse)
Query using a prepared statement, reading the
ReactiveResultSet with a ReactiveResultSetExtractor . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(ReactivePreparedStatementCreator psc,
PreparedStatementBinder psb,
ReactiveResultSetExtractor<T> rse)
Query using a prepared statement and a
PreparedStatementBinder implementation that knows how to bind values
to the query, reading the ReactiveResultSet with a ResultSetExtractor . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(ReactivePreparedStatementCreator psc,
ReactiveResultSetExtractor<T> rse) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(ReactivePreparedStatementCreator psc,
ReactiveResultSetExtractor<T> rse)
Query using a prepared statement, reading the
ReactiveResultSet with a ReactiveResultSetExtractor . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(com.datastax.driver.core.Statement statement,
ReactiveResultSetExtractor<T> rse) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(com.datastax.driver.core.Statement statement,
ReactiveResultSetExtractor<T> rse)
Execute a query given static CQL, reading the
ReactiveResultSet with a ReactiveResultSetExtractor . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(String cql,
PreparedStatementBinder psb,
ReactiveResultSetExtractor<T> rse) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(String cql,
PreparedStatementBinder psb,
ReactiveResultSetExtractor<T> rse)
Query using a prepared statement, reading the
ReactiveResultSet with a ReactiveResultSetExtractor . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(String cql,
ReactiveResultSetExtractor<T> resultSetExtractor) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(String cql,
ReactiveResultSetExtractor<T> rse)
Execute a query given static CQL, reading the
ReactiveResultSet with a ReactiveResultSetExtractor . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(String cql,
ReactiveResultSetExtractor<T> rse,
Object... args) |
<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 the
ReactiveResultSet with a ReactiveResultSetExtractor . |
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.