public abstract class AbstractReactiveCassandraQuery extends CassandraRepositoryQuerySupport
RepositoryQuery
implementations for Cassandra.CassandraRepositoryQuerySupport
log
Constructor and Description |
---|
AbstractReactiveCassandraQuery(ReactiveCassandraQueryMethod method,
ReactiveCassandraOperations operations)
Create a new
AbstractReactiveCassandraQuery from the given CassandraQueryMethod and
CassandraOperations . |
Modifier and Type | Method and Description |
---|---|
protected abstract com.datastax.driver.core.Statement |
createQuery(CassandraParameterAccessor accessor)
Creates a string query using the given
ParameterAccessor |
Object |
execute(Object[] parameters) |
ReactiveCassandraQueryMethod |
getQueryMethod() |
protected ReactiveCassandraOperations |
getReactiveCassandraOperations() |
protected abstract boolean |
isLimiting()
Return whether the query has an explicit limit set.
|
getEntityInstantiators, getQueryStatementCreator
public AbstractReactiveCassandraQuery(ReactiveCassandraQueryMethod method, ReactiveCassandraOperations operations)
AbstractReactiveCassandraQuery
from the given CassandraQueryMethod
and
CassandraOperations
.method
- must not be null.operations
- must not be null.protected ReactiveCassandraOperations getReactiveCassandraOperations()
public ReactiveCassandraQueryMethod getQueryMethod()
getQueryMethod
in interface RepositoryQuery
getQueryMethod
in class CassandraRepositoryQuerySupport
protected abstract com.datastax.driver.core.Statement createQuery(CassandraParameterAccessor accessor)
ParameterAccessor
accessor
- must not be null.protected abstract boolean isLimiting()
Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.