Spring/spring-data-cassandra
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATACASS-448 - Update Javadoc references to relocated packages.

Browse Source 
Fix Javadoc leftovers after package relocation.
This commit is contained in:
Mark Paluch
2017-06-06 12:28:52 +02:00
parent 61d9910048
commit d09e8d6e3f
62 changed files with 280 additions and 280 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/AsyncCassandraTemplate.java
View File

@@ -424,7 +424,7 @@ public class AsyncCassandraTemplate implements AsyncCassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.AsyncCassandraOperations#insert(java.lang.Object, org.springframework.cassandra.core.WriteOptions)
* @see org.springframework.data.cassandra.core.AsyncCassandraOperations#insert(java.lang.Object, org.springframework.data.cql.core.WriteOptions)
*/
@Override
public <T> ListenableFuture<T> insert(T entity, WriteOptions options) {
@@ -448,7 +448,7 @@ public class AsyncCassandraTemplate implements AsyncCassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.AsyncCassandraOperations#update(java.lang.Object, org.springframework.cassandra.core.WriteOptions)
* @see org.springframework.data.cassandra.core.AsyncCassandraOperations#update(java.lang.Object, org.springframework.data.cql.core.WriteOptions)
*/
@Override
public <T> ListenableFuture<T> update(T entity, WriteOptions options) {
@@ -472,7 +472,7 @@ public class AsyncCassandraTemplate implements AsyncCassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.AsyncCassandraOperations#delete(java.lang.Object, org.springframework.cassandra.core.QueryOptions)
* @see org.springframework.data.cassandra.core.AsyncCassandraOperations#delete(java.lang.Object, org.springframework.data.cql.core.QueryOptions)
*/
@Override
public <T> ListenableFuture<T> delete(T entity, QueryOptions options) {

8
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/CassandraAdminTemplate.java
View File

@@ -66,7 +66,7 @@ public class CassandraAdminTemplate extends CassandraTemplate implements Cassand
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraAdminOperations#createTable(boolean, org.springframework.cassandra.core.cql.CqlIdentifier, java.lang.Class, java.util.Map)
* @see org.springframework.data.cassandra.core.CassandraAdminOperations#createTable(boolean, org.springframework.data.cql.core.cql.CqlIdentifier, java.lang.Class, java.util.Map)
*/
@Override
public void createTable(boolean ifNotExists, CqlIdentifier tableName, Class<?> entityClass,
@@ -86,7 +86,7 @@ public class CassandraAdminTemplate extends CassandraTemplate implements Cassand
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraAdminOperations#dropTable(org.springframework.cassandra.core.cql.CqlIdentifier)
* @see org.springframework.data.cassandra.core.CassandraAdminOperations#dropTable(org.springframework.data.cql.core.cql.CqlIdentifier)
*/
@Override
public void dropTable(CqlIdentifier tableName) {
@@ -95,7 +95,7 @@ public class CassandraAdminTemplate extends CassandraTemplate implements Cassand
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraAdminOperations#dropUserType(org.springframework.cassandra.core.cql.CqlIdentifier)
* @see org.springframework.data.cassandra.core.CassandraAdminOperations#dropUserType(org.springframework.data.cql.core.cql.CqlIdentifier)
*/
@Override
public void dropUserType(CqlIdentifier typeName) {
@@ -107,7 +107,7 @@ public class CassandraAdminTemplate extends CassandraTemplate implements Cassand
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraAdminOperations#getTableMetadata(java.lang.String, org.springframework.cassandra.core.cql.CqlIdentifier)
* @see org.springframework.data.cassandra.core.CassandraAdminOperations#getTableMetadata(java.lang.String, org.springframework.data.cql.core.cql.CqlIdentifier)
*/
@Override
public Optional<TableMetadata> getTableMetadata(String keyspace, CqlIdentifier tableName) {

4
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/CassandraBatchTemplate.java
View File

@@ -102,7 +102,7 @@ class CassandraBatchTemplate implements CassandraBatchOperations {
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraBatchOperations#insert(java.lang.Iterable, org.springframework.cassandra.core.WriteOptions)
* @see org.springframework.data.cassandra.core.CassandraBatchOperations#insert(java.lang.Iterable, org.springframework.data.cql.core.WriteOptions)
*/
@Override
public CassandraBatchOperations insert(Iterable<?> entities, WriteOptions options) {
@@ -140,7 +140,7 @@ class CassandraBatchTemplate implements CassandraBatchOperations {
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraBatchOperations#update(java.lang.Iterable, org.springframework.cassandra.core.WriteOptions)
* @see org.springframework.data.cassandra.core.CassandraBatchOperations#update(java.lang.Iterable, org.springframework.data.cql.core.WriteOptions)
*/
@Override
public CassandraBatchOperations update(Iterable<?> entities, WriteOptions options) {

14
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/CassandraTemplate.java
View File

@@ -208,7 +208,7 @@ public class CassandraTemplate implements CassandraOperations {
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraOperationsNG#stream(java.lang.String, java.lang.Class)
* @see org.springframework.data.cassandra.core.CassandraOperations#stream(java.lang.String, java.lang.Class)
*/
@Override
public <T> Stream<T> stream(String cql, Class<T> entityClass) throws DataAccessException {
@@ -250,7 +250,7 @@ public class CassandraTemplate implements CassandraOperations {
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraOperationsNG#stream(com.datastax.driver.core.Statement, java.lang.Class)
* @see org.springframework.data.cassandra.core.CassandraOperations#stream(com.datastax.driver.core.Statement, java.lang.Class)
*/
@Override
public <T> Stream<T> stream(Statement statement, Class<T> entityClass) throws DataAccessException {
@@ -433,7 +433,7 @@ public class CassandraTemplate implements CassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraOperations#insert(java.lang.Object, org.springframework.cassandra.core.WriteOptions)
* @see org.springframework.data.cassandra.core.CassandraOperations#insert(java.lang.Object, org.springframework.data.cql.core.WriteOptions)
*/
@Override
public <T> T insert(T entity, WriteOptions options) {
@@ -456,7 +456,7 @@ public class CassandraTemplate implements CassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraOperations#update(java.lang.Object, org.springframework.cassandra.core.WriteOptions)
* @see org.springframework.data.cassandra.core.CassandraOperations#update(java.lang.Object, org.springframework.data.cql.core.WriteOptions)
*/
@Override
public <T> T update(T entity, WriteOptions options) {
@@ -479,7 +479,7 @@ public class CassandraTemplate implements CassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraOperations#delete(java.lang.Object, org.springframework.cassandra.core.QueryOptions)
* @see org.springframework.data.cassandra.core.CassandraOperations#delete(java.lang.Object, org.springframework.data.cql.core.QueryOptions)
*/
@Override
public <T> T delete(T entity, QueryOptions options) {
@@ -532,7 +532,7 @@ public class CassandraTemplate implements CassandraOperations {
/*
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraOperationsNG#getTableName(java.lang.Class)
* @see org.springframework.data.cassandra.core.CassandraOperations#getTableName(java.lang.Class)
*/
@Override
public CqlIdentifier getTableName(Class<?> entityClass) {
@@ -541,7 +541,7 @@ public class CassandraTemplate implements CassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.CassandraOperationsNG#batchOps()
* @see org.springframework.data.cassandra.core.CassandraOperations#batchOps()
*/
@Override
public CassandraBatchOperations batchOps() {

12
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/ReactiveCassandraTemplate.java
View File

@@ -380,7 +380,7 @@ public class ReactiveCassandraTemplate implements ReactiveCassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#insert(java.lang.Object, org.springframework.cassandra.core.WriteOptions)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#insert(java.lang.Object, org.springframework.data.cql.core.WriteOptions)
*/
@Override
public <T> Mono<T> insert(T entity, WriteOptions options) {
@@ -417,7 +417,7 @@ public class ReactiveCassandraTemplate implements ReactiveCassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#insert(org.reactivestreams.Publisher, org.springframework.cassandra.core.WriteOptions)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#insert(org.reactivestreams.Publisher, org.springframework.data.cql.core.WriteOptions)
*/
@Override
public <T> Flux<T> insert(Publisher<? extends T> entities, WriteOptions options) {
@@ -438,7 +438,7 @@ public class ReactiveCassandraTemplate implements ReactiveCassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#update(java.lang.Object, org.springframework.cassandra.core.WriteOptions)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#update(java.lang.Object, org.springframework.data.cql.core.WriteOptions)
*/
@Override
public <T> Mono<T> update(T entity, WriteOptions options) {
@@ -475,7 +475,7 @@ public class ReactiveCassandraTemplate implements ReactiveCassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#update(org.reactivestreams.Publisher, org.springframework.cassandra.core.WriteOptions)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#update(org.reactivestreams.Publisher, org.springframework.data.cql.core.WriteOptions)
*/
@Override
public <T> Flux<T> update(Publisher<? extends T> entities, WriteOptions options) {
@@ -515,7 +515,7 @@ public class ReactiveCassandraTemplate implements ReactiveCassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#delete(java.lang.Object, org.springframework.cassandra.core.QueryOptions)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#delete(java.lang.Object, org.springframework.data.cql.core.QueryOptions)
*/
@Override
public <T> Mono<T> delete(T entity, QueryOptions options) {
@@ -552,7 +552,7 @@ public class ReactiveCassandraTemplate implements ReactiveCassandraOperations {
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#delete(org.reactivestreams.Publisher, org.springframework.cassandra.core.QueryOptions)
* @see org.springframework.data.cassandra.core.ReactiveCassandraOperations#delete(org.reactivestreams.Publisher, org.springframework.data.cql.core.QueryOptions)
*/
@Override
public <T> Flux<T> delete(Publisher<? extends T> entities, QueryOptions options) {

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/convert/BasicCassandraRowValueProvider.java
View File

@@ -78,7 +78,7 @@ public class BasicCassandraRowValueProvider implements CassandraRowValueProvider
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.core.convert.CassandraValueProvider#hasProperty(org.springframework.data.cassandra.mapping.CassandraPersistentProperty)
* @see org.springframework.data.cassandra.core.convert.CassandraValueProvider#hasProperty(org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty)
*/
@Override
public boolean hasProperty(CassandraPersistentProperty property) {

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/convert/CassandraUDTValueProvider.java
View File

@@ -78,7 +78,7 @@ public class CassandraUDTValueProvider implements CassandraValueProvider {
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.core.convert.CassandraValueProvider#hasProperty(org.springframework.data.cassandra.mapping.CassandraPersistentProperty)
* @see org.springframework.data.cassandra.core.convert.CassandraValueProvider#hasProperty(org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty)
*/
@Override
public boolean hasProperty(CassandraPersistentProperty property) {

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/convert/MappingCassandraConverter.java
View File

@@ -950,7 +950,7 @@ public class MappingCassandraConverter extends AbstractCassandraConverter
private final CassandraValueProvider parent;
/* (non-Javadoc)
* @see org.springframework.data.cassandra.core.convert.CassandraValueProvider#hasProperty(org.springframework.data.cassandra.mapping.CassandraPersistentProperty)
* @see org.springframework.data.cassandra.core.convert.CassandraValueProvider#hasProperty(org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty)
*/
@Override
public boolean hasProperty(CassandraPersistentProperty property) {

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/convert/UpdateMapper.java
View File

@@ -49,7 +49,7 @@ import com.datastax.driver.core.DataType.Name;
* @author Mark Paluch
* @see org.springframework.data.cassandra.core.query.Filter
* @see org.springframework.data.cassandra.core.query.Update
* @see org.springframework.data.cassandra.mapping.CassandraPersistentEntity
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentEntity
* @see org.springframework.data.mapping.PersistentProperty
* @see org.springframework.data.util.TypeInformation
* @since 2.0

12
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/mapping/BasicCassandraPersistentEntity.java
View File

@@ -128,7 +128,7 @@ public class BasicCassandraPersistentEntity<T> extends BasicPersistentEntity<T,
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentEntity#isCompositePrimaryKey()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentEntity#isCompositePrimaryKey()
*/
@Override
public boolean isCompositePrimaryKey() {
@@ -168,7 +168,7 @@ public class BasicCassandraPersistentEntity<T> extends BasicPersistentEntity<T,
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentEntity#setForceQuote(boolean)
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentEntity#setForceQuote(boolean)
*/
@Override
public void setForceQuote(boolean forceQuote) {
@@ -183,7 +183,7 @@ public class BasicCassandraPersistentEntity<T> extends BasicPersistentEntity<T,
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentEntity#setTableName(org.springframework.cassandra.core.cql.CqlIdentifier)
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentEntity#setTableName(org.springframework.data.cql.core.cql.CqlIdentifier)
*/
@Override
public void setTableName(CqlIdentifier tableName) {
@@ -193,7 +193,7 @@ public class BasicCassandraPersistentEntity<T> extends BasicPersistentEntity<T,
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentEntity#getTableName()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentEntity#getTableName()
*/
@Override
public CqlIdentifier getTableName() {
@@ -215,7 +215,7 @@ public class BasicCassandraPersistentEntity<T> extends BasicPersistentEntity<T,
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentEntity#isUserDefinedType()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentEntity#isUserDefinedType()
*/
@Override
public boolean isUserDefinedType() {
@@ -223,7 +223,7 @@ public class BasicCassandraPersistentEntity<T> extends BasicPersistentEntity<T,
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentEntity#getUserType()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentEntity#getUserType()
*/
@Override
public UserType getUserType() {

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/mapping/BasicCassandraPersistentEntityMetadataVerifier.java
View File

@@ -37,7 +37,7 @@ public class BasicCassandraPersistentEntityMetadataVerifier implements Cassandra
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentEntityMetadataVerifier#verify(org.springframework.data.cassandra.mapping.CassandraPersistentEntity)
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentEntityMetadataVerifier#verify(org.springframework.data.cassandra.core.mapping.CassandraPersistentEntity)
*/
@Override
public void verify(CassandraPersistentEntity<?> entity) throws MappingException {

20
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/mapping/BasicCassandraPersistentProperty.java
View File

@@ -124,7 +124,7 @@ public class BasicCassandraPersistentProperty extends AnnotationBasedPersistentP
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentProperty#getColumnName()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty#getColumnName()
*/
@Override
public CqlIdentifier getColumnName() {
@@ -137,7 +137,7 @@ public class BasicCassandraPersistentProperty extends AnnotationBasedPersistentP
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentProperty#getPrimaryKeyOrdering()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty#getPrimaryKeyOrdering()
*/
@Override
public Optional<Ordering> getPrimaryKeyOrdering() {
@@ -145,7 +145,7 @@ public class BasicCassandraPersistentProperty extends AnnotationBasedPersistentP
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentProperty#getDataType()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty#getDataType()
*/
@Override
public DataType getDataType() {
@@ -277,7 +277,7 @@ public class BasicCassandraPersistentProperty extends AnnotationBasedPersistentP
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentProperty#isCompositePrimaryKey()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty#isCompositePrimaryKey()
*/
@Override
public boolean isCompositePrimaryKey() {
@@ -285,7 +285,7 @@ public class BasicCassandraPersistentProperty extends AnnotationBasedPersistentP
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentProperty#isPrimaryKeyColumn()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty#isPrimaryKeyColumn()
*/
@Override
public boolean isPrimaryKeyColumn() {
@@ -293,7 +293,7 @@ public class BasicCassandraPersistentProperty extends AnnotationBasedPersistentP
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentProperty#isPartitionKeyColumn()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty#isPartitionKeyColumn()
*/
@Override
public boolean isPartitionKeyColumn() {
@@ -303,7 +303,7 @@ public class BasicCassandraPersistentProperty extends AnnotationBasedPersistentP
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentProperty#isClusterKeyColumn()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty#isClusterKeyColumn()
*/
@Override
public boolean isClusterKeyColumn() {
@@ -353,7 +353,7 @@ public class BasicCassandraPersistentProperty extends AnnotationBasedPersistentP
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentProperty#setColumnName(org.springframework.cassandra.core.cql.CqlIdentifier)
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty#setColumnName(org.springframework.data.cql.core.cql.CqlIdentifier)
*/
@Override
public void setColumnName(CqlIdentifier columnName) {
@@ -364,7 +364,7 @@ public class BasicCassandraPersistentProperty extends AnnotationBasedPersistentP
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentProperty#setForceQuote(boolean)
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty#setForceQuote(boolean)
*/
@Override
public void setForceQuote(boolean forceQuote) {
@@ -399,7 +399,7 @@ public class BasicCassandraPersistentProperty extends AnnotationBasedPersistentP
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentProperty#isMapLike()
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty#isMapLike()
*/
@Override
public boolean isMapLike() {

6
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/mapping/CassandraUserTypePersistentEntity.java
View File

@@ -56,7 +56,7 @@ public class CassandraUserTypePersistentEntity<T> extends BasicCassandraPersiste
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.BasicCassandraPersistentEntity#determineTableName()
* @see org.springframework.data.cassandra.core.mapping.BasicCassandraPersistentEntity#determineTableName()
*/
@Override
protected CqlIdentifier determineTableName() {
@@ -67,7 +67,7 @@ public class CassandraUserTypePersistentEntity<T> extends BasicCassandraPersiste
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.BasicCassandraPersistentEntity#isUserDefinedType()
* @see org.springframework.data.cassandra.core.mapping.BasicCassandraPersistentEntity#isUserDefinedType()
*/
@Override
public boolean isUserDefinedType() {
@@ -75,7 +75,7 @@ public class CassandraUserTypePersistentEntity<T> extends BasicCassandraPersiste
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.BasicCassandraPersistentEntity#getUserType()
* @see org.springframework.data.cassandra.core.mapping.BasicCassandraPersistentEntity#getUserType()
*/
@Override
public UserType getUserType() {

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/mapping/CompositeCassandraPersistentEntityMetadataVerifier.java
View File

@@ -60,7 +60,7 @@ public class CompositeCassandraPersistentEntityMetadataVerifier implements Cassa
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentEntityMetadataVerifier#verify(org.springframework.data.cassandra.mapping.CassandraPersistentEntity)
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentEntityMetadataVerifier#verify(org.springframework.data.cassandra.core.mapping.CassandraPersistentEntity)
*/
@Override
public void verify(CassandraPersistentEntity<?> entity) throws MappingException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/mapping/PrimaryKeyClassEntityMetadataVerifier.java
View File

@@ -33,7 +33,7 @@ public class PrimaryKeyClassEntityMetadataVerifier implements CassandraPersisten
/*
* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.CassandraPersistentEntityMetadataVerifier#verify(org.springframework.data.cassandra.mapping.CassandraPersistentEntity)
* @see org.springframework.data.cassandra.core.mapping.CassandraPersistentEntityMetadataVerifier#verify(org.springframework.data.cassandra.core.mapping.CassandraPersistentEntity)
*/
@Override
public void verify(CassandraPersistentEntity<?> entity) throws MappingException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/mapping/SimpleUserTypeResolver.java
View File

@@ -50,7 +50,7 @@ public class SimpleUserTypeResolver implements UserTypeResolver {
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.mapping.UserTypeResolver#resolveType(org.springframework.cassandra.core.cql.CqlIdentifier)
* @see org.springframework.data.cassandra.core.mapping.UserTypeResolver#resolveType(org.springframework.data.cql.core.cql.CqlIdentifier)
*/
@Override
public UserType resolveType(CqlIdentifier typeName) {

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/query/ColumnName.java
View File

@@ -29,7 +29,7 @@ import org.springframework.util.Assert;
* Implementing classes must provide either {@link #getColumnName()} or {@link #getCqlIdentifier()}.
*
* @author Mark Paluch
* @see org.springframework.cassandra.core.cql.CqlIdentifier
* @see org.springframework.data.cql.core.cql.CqlIdentifier
* @since 2.0
*/
public abstract class ColumnName {

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/query/Columns.java
View File

@@ -37,7 +37,7 @@ import org.springframework.util.StringUtils;
* included using a {@link Selector}.
*
* @author Mark Paluch
* @see org.springframework.cassandra.core.cql.CqlIdentifier
* @see org.springframework.data.cql.core.cql.CqlIdentifier
* @see org.springframework.data.cassandra.core.query.ColumnName
* @see Selector
* @see FunctionCall

2
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/ConvertingParameterAccessor.java
View File

@@ -277,7 +277,7 @@ class ConvertingParameterAccessor implements CassandraParameterAccessor {
}
/* (non-Javadoc)
* @see org.springframework.data.cassandra.repository.query.ConvertingParameterAccessor.PotentiallyConvertingIterator#nextConverted(org.springframework.data.cassandra.mapping.CassandraPersistentProperty)
* @see org.springframework.data.cassandra.repository.query.ConvertingParameterAccessor.PotentiallyConvertingIterator#nextConverted(org.springframework.data.cassandra.core.mapping.CassandraPersistentProperty)
*/
@Override
public Object nextConverted(CassandraPersistentProperty property) {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/ArgumentPreparedStatementBinder.java
View File

@@ -39,7 +39,7 @@ public class ArgumentPreparedStatementBinder implements PreparedStatementBinder
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.PreparedStatementBinder#bindValues(com.datastax.driver.core.PreparedStatement)
* @see org.springframework.data.cql.core.PreparedStatementBinder#bindValues(com.datastax.driver.core.PreparedStatement)
*/
@Override
public BoundStatement bindValues(PreparedStatement ps) throws DriverException {

90
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/AsyncCqlTemplate.java
View File

@@ -61,7 +61,7 @@ import com.google.common.util.concurrent.Futures;
* it.
* <p>
* All CQL operations performed by this class are logged at debug level, using
* "org.springframework.cassandra.core.CqlTemplate" as log category.
* "org.springframework.data.cql.core.CqlTemplate" as log category.
* <p>
* <b>NOTE: An instance of this class is thread-safe once configured.</b>
*
@@ -120,7 +120,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#execute(org.springframework.cassandra.core.AsyncSessionCallback)
* @see org.springframework.data.cql.core.AsyncCqlOperations#execute(org.springframework.data.cql.core.AsyncSessionCallback)
*/
@Override
public <T> ListenableFuture<T> execute(AsyncSessionCallback<T> action) throws DataAccessException {
@@ -140,7 +140,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#execute(java.lang.String)
* @see org.springframework.data.cql.core.AsyncCqlOperations#execute(java.lang.String)
*/
@Override
public ListenableFuture<Boolean> execute(String cql) throws DataAccessException {
@@ -152,7 +152,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(java.lang.String, org.springframework.cassandra.core.ResultSetExtractor)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(java.lang.String, org.springframework.data.cql.core.ResultSetExtractor)
*/
@Override
public <T> ListenableFuture<T> query(String cql, ResultSetExtractor<T> resultSetExtractor)
@@ -180,7 +180,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(java.lang.String, org.springframework.cassandra.core.RowCallbackHandler)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(java.lang.String, org.springframework.data.cql.core.RowCallbackHandler)
*/
@Override
public ListenableFuture<Void> query(String cql, RowCallbackHandler rowCallbackHandler) throws DataAccessException {
@@ -193,7 +193,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(java.lang.String, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(java.lang.String, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> ListenableFuture<List<T>> query(String cql, RowMapper<T> rowMapper) throws DataAccessException {
@@ -202,7 +202,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForList(java.lang.String)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForList(java.lang.String)
*/
@Override
public ListenableFuture<List<Map<String, Object>>> queryForList(String cql) throws DataAccessException {
@@ -211,7 +211,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForList(java.lang.String, java.lang.Class)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForList(java.lang.String, java.lang.Class)
*/
@Override
public <T> ListenableFuture<List<T>> queryForList(String cql, Class<T> elementType) throws DataAccessException {
@@ -220,7 +220,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForMap(java.lang.String)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForMap(java.lang.String)
*/
@Override
public ListenableFuture<Map<String, Object>> queryForMap(String cql) throws DataAccessException {
@@ -229,7 +229,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForObject(java.lang.String, java.lang.Class)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForObject(java.lang.String, java.lang.Class)
*/
@Override
public <T> ListenableFuture<T> queryForObject(String cql, Class<T> requiredType) throws DataAccessException {
@@ -238,7 +238,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForObject(java.lang.String, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForObject(java.lang.String, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> ListenableFuture<T> queryForObject(String cql, RowMapper<T> rowMapper) throws DataAccessException {
@@ -251,7 +251,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForResultSet(java.lang.String)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForResultSet(java.lang.String)
*/
@Override
public ListenableFuture<ResultSet> queryForResultSet(String cql) throws DataAccessException {
@@ -264,7 +264,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#execute(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.AsyncCqlOperations#execute(com.datastax.driver.core.Statement)
*/
@Override
public ListenableFuture<Boolean> execute(Statement statement) throws DataAccessException {
@@ -276,7 +276,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(com.datastax.driver.core.Statement, org.springframework.cassandra.core.ResultSetExtractor)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(com.datastax.driver.core.Statement, org.springframework.data.cql.core.ResultSetExtractor)
*/
@Override
public <T> ListenableFuture<T> query(Statement statement, ResultSetExtractor<T> resultSetExtractor)
@@ -305,7 +305,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(com.datastax.driver.core.Statement, org.springframework.cassandra.core.RowCallbackHandler)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(com.datastax.driver.core.Statement, org.springframework.data.cql.core.RowCallbackHandler)
*/
@Override
public ListenableFuture<Void> query(Statement statement, RowCallbackHandler rowCallbackHandler)
@@ -319,7 +319,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(com.datastax.driver.core.Statement, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(com.datastax.driver.core.Statement, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> ListenableFuture<List<T>> query(Statement statement, RowMapper<T> rowMapper) throws DataAccessException {
@@ -328,7 +328,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForList(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForList(com.datastax.driver.core.Statement)
*/
@Override
public ListenableFuture<List<Map<String, Object>>> queryForList(Statement statement) throws DataAccessException {
@@ -337,7 +337,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForList(com.datastax.driver.core.Statement, java.lang.Class)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForList(com.datastax.driver.core.Statement, java.lang.Class)
*/
@Override
public <T> ListenableFuture<List<T>> queryForList(Statement statement, Class<T> elementType)
@@ -347,7 +347,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForMap(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForMap(com.datastax.driver.core.Statement)
*/
@Override
public ListenableFuture<Map<String, Object>> queryForMap(Statement statement) throws DataAccessException {
@@ -356,7 +356,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForObject(com.datastax.driver.core.Statement, java.lang.Class)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForObject(com.datastax.driver.core.Statement, java.lang.Class)
*/
@Override
public <T> ListenableFuture<T> queryForObject(Statement statement, Class<T> requiredType) throws DataAccessException {
@@ -365,7 +365,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForObject(com.datastax.driver.core.Statement, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForObject(com.datastax.driver.core.Statement, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> ListenableFuture<T> queryForObject(Statement statement, RowMapper<T> rowMapper)
@@ -379,7 +379,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForResultSet(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForResultSet(com.datastax.driver.core.Statement)
*/
@Override
public ListenableFuture<ResultSet> queryForResultSet(Statement statement) throws DataAccessException {
@@ -392,7 +392,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#execute(org.springframework.cassandra.core.AsyncPreparedStatementCreator)
* @see org.springframework.data.cql.core.AsyncCqlOperations#execute(org.springframework.data.cql.core.AsyncPreparedStatementCreator)
*/
@Override
public ListenableFuture<Boolean> execute(AsyncPreparedStatementCreator preparedStatementCreator)
@@ -403,7 +403,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#execute(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.AsyncCqlOperations#execute(java.lang.String, java.lang.Object[])
*/
@Override
public ListenableFuture<Boolean> execute(String cql, Object... args) throws DataAccessException {
@@ -412,7 +412,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#execute(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder)
* @see org.springframework.data.cql.core.AsyncCqlOperations#execute(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder)
*/
@Override
public ListenableFuture<Boolean> execute(String cql, PreparedStatementBinder preparedStatementBinder)
@@ -423,7 +423,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#execute(java.lang.String, org.springframework.cassandra.core.PreparedStatementCallback)
* @see org.springframework.data.cql.core.AsyncCqlOperations#execute(java.lang.String, org.springframework.data.cql.core.PreparedStatementCallback)
*/
@Override
public <T> ListenableFuture<T> execute(String cql, PreparedStatementCallback<T> action) throws DataAccessException {
@@ -432,7 +432,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#execute(org.springframework.cassandra.core.AsyncPreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementCallback)
* @see org.springframework.data.cql.core.AsyncCqlOperations#execute(org.springframework.data.cql.core.AsyncPreparedStatementCreator, org.springframework.data.cql.core.PreparedStatementCallback)
*/
@Override
public <T> ListenableFuture<T> execute(AsyncPreparedStatementCreator preparedStatementCreator,
@@ -463,7 +463,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(org.springframework.cassandra.core.AsyncPreparedStatementCreator, org.springframework.cassandra.core.ResultSetExtractor)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(org.springframework.data.cql.core.AsyncPreparedStatementCreator, org.springframework.data.cql.core.ResultSetExtractor)
*/
@Override
public <T> ListenableFuture<T> query(AsyncPreparedStatementCreator preparedStatementCreator,
@@ -474,7 +474,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(org.springframework.cassandra.core.AsyncPreparedStatementCreator, org.springframework.cassandra.core.RowCallbackHandler)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(org.springframework.data.cql.core.AsyncPreparedStatementCreator, org.springframework.data.cql.core.RowCallbackHandler)
*/
@Override
public ListenableFuture<Void> query(AsyncPreparedStatementCreator preparedStatementCreator,
@@ -488,7 +488,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(org.springframework.cassandra.core.AsyncPreparedStatementCreator, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(org.springframework.data.cql.core.AsyncPreparedStatementCreator, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> ListenableFuture<List<T>> query(AsyncPreparedStatementCreator preparedStatementCreator,
@@ -499,7 +499,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(org.springframework.cassandra.core.AsyncPreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.ResultSetExtractor)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(org.springframework.data.cql.core.AsyncPreparedStatementCreator, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.ResultSetExtractor)
*/
@Override
public <T> ListenableFuture<T> query(AsyncPreparedStatementCreator preparedStatementCreator,
@@ -569,7 +569,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(org.springframework.cassandra.core.AsyncPreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowCallbackHandler)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(org.springframework.data.cql.core.AsyncPreparedStatementCreator, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.RowCallbackHandler)
*/
@Override
public ListenableFuture<Void> query(AsyncPreparedStatementCreator preparedStatementCreator,
@@ -585,7 +585,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(org.springframework.cassandra.core.AsyncPreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(org.springframework.data.cql.core.AsyncPreparedStatementCreator, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> ListenableFuture<List<T>> query(AsyncPreparedStatementCreator preparedStatementCreator,
@@ -596,7 +596,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(java.lang.String, org.springframework.cassandra.core.ResultSetExtractor, java.lang.Object[])
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(java.lang.String, org.springframework.data.cql.core.ResultSetExtractor, java.lang.Object[])
*/
@Override
public <T> ListenableFuture<T> query(String cql, ResultSetExtractor<T> resultSetExtractor, Object... args)
@@ -607,7 +607,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(java.lang.String, org.springframework.cassandra.core.RowCallbackHandler, java.lang.Object[])
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(java.lang.String, org.springframework.data.cql.core.RowCallbackHandler, java.lang.Object[])
*/
@Override
public ListenableFuture<Void> query(String cql, RowCallbackHandler rowCallbackHandler, Object... args)
@@ -622,7 +622,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(java.lang.String, org.springframework.cassandra.core.RowMapper, java.lang.Object[])
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(java.lang.String, org.springframework.data.cql.core.RowMapper, java.lang.Object[])
*/
@Override
public <T> ListenableFuture<List<T>> query(String cql, RowMapper<T> rowMapper, Object... args)
@@ -634,7 +634,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.ResultSetExtractor)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.ResultSetExtractor)
*/
@Override
public <T> ListenableFuture<T> query(String cql, PreparedStatementBinder preparedStatementBinder,
@@ -645,7 +645,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowCallbackHandler)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.RowCallbackHandler)
*/
@Override
public ListenableFuture<Void> query(String cql, PreparedStatementBinder preparedStatementBinder,
@@ -660,7 +660,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.AsyncCqlOperations#query(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> ListenableFuture<List<T>> query(String cql, PreparedStatementBinder preparedStatementBinder,
@@ -671,7 +671,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForList(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForList(java.lang.String, java.lang.Object[])
*/
@Override
public ListenableFuture<List<Map<String, Object>>> queryForList(String cql, Object... args)
@@ -683,7 +683,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForList(java.lang.String, java.lang.Class, java.lang.Object[])
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForList(java.lang.String, java.lang.Class, java.lang.Object[])
*/
@Override
public <T> ListenableFuture<List<T>> queryForList(String cql, Class<T> elementType, Object... args)
@@ -695,7 +695,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForMap(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForMap(java.lang.String, java.lang.Object[])
*/
@Override
public ListenableFuture<Map<String, Object>> queryForMap(String cql, Object... args) throws DataAccessException {
@@ -704,7 +704,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForObject(java.lang.String, java.lang.Class, java.lang.Object[])
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForObject(java.lang.String, java.lang.Class, java.lang.Object[])
*/
@Override
public <T> ListenableFuture<T> queryForObject(String cql, Class<T> requiredType, Object... args)
@@ -715,7 +715,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForObject(java.lang.String, org.springframework.cassandra.core.RowMapper, java.lang.Object[])
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForObject(java.lang.String, org.springframework.data.cql.core.RowMapper, java.lang.Object[])
*/
@Override
public <T> ListenableFuture<T> queryForObject(String cql, RowMapper<T> rowMapper, Object... args)
@@ -730,7 +730,7 @@ public class AsyncCqlTemplate extends CqlTemplateSupport implements AsyncCqlOper
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.AsyncCqlOperations#queryForResultSet(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.AsyncCqlOperations#queryForResultSet(java.lang.String, java.lang.Object[])
*/
@Override
public ListenableFuture<ResultSet> queryForResultSet(String cql, Object... args) throws DataAccessException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/CachedPreparedStatementCreator.java
View File

@@ -67,7 +67,7 @@ public class CachedPreparedStatementCreator implements PreparedStatementCreator
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.PreparedStatementCreator#createPreparedStatement(com.datastax.driver.core.Session)
* @see org.springframework.data.cql.core.PreparedStatementCreator#createPreparedStatement(com.datastax.driver.core.Session)
*/
@Override
public PreparedStatement createPreparedStatement(Session session) throws DriverException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/ColumnMapRowMapper.java
View File

@@ -42,7 +42,7 @@ import com.datastax.driver.core.Row;
public class ColumnMapRowMapper implements RowMapper<Map<String, Object>> {
/* (non-Javadoc)
* @see org.springframework.cassandra.core.RowMapper#mapRow(com.datastax.driver.core.Row, int)
* @see org.springframework.data.cql.core.RowMapper#mapRow(com.datastax.driver.core.Row, int)
*/
@Override
public Map<String, Object> mapRow(Row rs, int rowNum) {

100
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/CqlTemplate.java
View File

@@ -58,7 +58,7 @@ import com.datastax.driver.core.exceptions.DriverException;
* it.
* <p>
* All CQL operations performed by this class are logged at debug level, using
* "org.springframework.cassandra.core.CqlTemplate" as log category.
* "org.springframework.data.cql.core.CqlTemplate" as log category.
* <p>
* <b>NOTE: An instance of this class is thread-safe once configured.</b>
*
@@ -119,7 +119,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#execute(org.springframework.cassandra.core.SessionCallback)
* @see org.springframework.data.cql.core.CqlOperations#execute(org.springframework.data.cql.core.SessionCallback)
*/
@Override
public <T> T execute(SessionCallback<T> action) throws DataAccessException {
@@ -139,7 +139,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#execute(java.lang.String)
* @see org.springframework.data.cql.core.CqlOperations#execute(java.lang.String)
*/
@Override
public boolean execute(String cql) throws DataAccessException {
@@ -151,7 +151,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(java.lang.String, org.springframework.cassandra.core.ResultSetExtractor)
* @see org.springframework.data.cql.core.CqlOperations#query(java.lang.String, org.springframework.data.cql.core.ResultSetExtractor)
*/
@Override
public <T> T query(String cql, ResultSetExtractor<T> resultSetExtractor) throws DataAccessException {
@@ -176,7 +176,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(java.lang.String, org.springframework.cassandra.core.RowCallbackHandler)
* @see org.springframework.data.cql.core.CqlOperations#query(java.lang.String, org.springframework.data.cql.core.RowCallbackHandler)
*/
@Override
public void query(String cql, RowCallbackHandler rowCallbackHandler) throws DataAccessException {
@@ -185,7 +185,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(java.lang.String, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.CqlOperations#query(java.lang.String, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> List<T> query(String cql, RowMapper<T> rowMapper) throws DataAccessException {
@@ -194,7 +194,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForList(java.lang.String)
* @see org.springframework.data.cql.core.CqlOperations#queryForList(java.lang.String)
*/
@Override
public List<Map<String, Object>> queryForList(String cql) throws DataAccessException {
@@ -203,7 +203,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForList(java.lang.String, java.lang.Class)
* @see org.springframework.data.cql.core.CqlOperations#queryForList(java.lang.String, java.lang.Class)
*/
@Override
public <T> List<T> queryForList(String cql, Class<T> elementType) throws DataAccessException {
@@ -212,7 +212,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForMap(java.lang.String)
* @see org.springframework.data.cql.core.CqlOperations#queryForMap(java.lang.String)
*/
@Override
public Map<String, Object> queryForMap(String cql) throws DataAccessException {
@@ -221,7 +221,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForObject(java.lang.String, java.lang.Class)
* @see org.springframework.data.cql.core.CqlOperations#queryForObject(java.lang.String, java.lang.Class)
*/
@Override
public <T> T queryForObject(String cql, Class<T> requiredType) throws DataAccessException {
@@ -230,7 +230,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForObject(java.lang.String, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.CqlOperations#queryForObject(java.lang.String, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> T queryForObject(String cql, RowMapper<T> rowMapper) throws DataAccessException {
@@ -239,7 +239,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForResultSet(java.lang.String)
* @see org.springframework.data.cql.core.CqlOperations#queryForResultSet(java.lang.String)
*/
@Override
public ResultSet queryForResultSet(String cql) throws DataAccessException {
@@ -248,7 +248,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForRows(java.lang.String)
* @see org.springframework.data.cql.core.CqlOperations#queryForRows(java.lang.String)
*/
@Override
public Iterable<Row> queryForRows(String cql) throws DataAccessException {
@@ -261,7 +261,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#execute(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.CqlOperations#execute(com.datastax.driver.core.Statement)
*/
@Override
public boolean execute(Statement statement) throws DataAccessException {
@@ -273,7 +273,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(com.datastax.driver.core.Statement, org.springframework.cassandra.core.ResultSetExtractor)
* @see org.springframework.data.cql.core.CqlOperations#query(com.datastax.driver.core.Statement, org.springframework.data.cql.core.ResultSetExtractor)
*/
@Override
public <T> T query(Statement statement, ResultSetExtractor<T> resultSetExtractor) throws DataAccessException {
@@ -294,7 +294,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(com.datastax.driver.core.Statement, org.springframework.cassandra.core.RowCallbackHandler)
* @see org.springframework.data.cql.core.CqlOperations#query(com.datastax.driver.core.Statement, org.springframework.data.cql.core.RowCallbackHandler)
*/
@Override
public void query(Statement statement, RowCallbackHandler rowCallbackHandler) throws DataAccessException {
@@ -303,7 +303,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(com.datastax.driver.core.Statement, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.CqlOperations#query(com.datastax.driver.core.Statement, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> List<T> query(Statement statement, RowMapper<T> rowMapper) throws DataAccessException {
@@ -312,7 +312,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForList(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.CqlOperations#queryForList(com.datastax.driver.core.Statement)
*/
@Override
public List<Map<String, Object>> queryForList(Statement statement) throws DataAccessException {
@@ -321,7 +321,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForList(com.datastax.driver.core.Statement, java.lang.Class)
* @see org.springframework.data.cql.core.CqlOperations#queryForList(com.datastax.driver.core.Statement, java.lang.Class)
*/
@Override
public <T> List<T> queryForList(Statement statement, Class<T> elementType) throws DataAccessException {
@@ -330,7 +330,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForMap(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.CqlOperations#queryForMap(com.datastax.driver.core.Statement)
*/
@Override
public Map<String, Object> queryForMap(Statement statement) throws DataAccessException {
@@ -339,7 +339,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForObject(com.datastax.driver.core.Statement, java.lang.Class)
* @see org.springframework.data.cql.core.CqlOperations#queryForObject(com.datastax.driver.core.Statement, java.lang.Class)
*/
@Override
public <T> T queryForObject(Statement statement, Class<T> requiredType) throws DataAccessException {
@@ -348,7 +348,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForObject(com.datastax.driver.core.Statement, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.CqlOperations#queryForObject(com.datastax.driver.core.Statement, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> T queryForObject(Statement statement, RowMapper<T> rowMapper) throws DataAccessException {
@@ -357,7 +357,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForResultSet(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.CqlOperations#queryForResultSet(com.datastax.driver.core.Statement)
*/
@Override
public ResultSet queryForResultSet(Statement statement) throws DataAccessException {
@@ -366,7 +366,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForRows(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.CqlOperations#queryForRows(com.datastax.driver.core.Statement)
*/
@Override
public Iterable<Row> queryForRows(Statement statement) throws DataAccessException {
@@ -379,7 +379,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#execute(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#execute(java.lang.String, java.lang.Object[])
*/
@Override
public boolean execute(String cql, Object... args) throws DataAccessException {
@@ -388,7 +388,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#execute(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder)
* @see org.springframework.data.cql.core.CqlOperations#execute(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder)
*/
@Override
public boolean execute(String cql, PreparedStatementBinder preparedStatementBinder) throws DataAccessException {
@@ -397,7 +397,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#execute(java.lang.String, org.springframework.cassandra.core.PreparedStatementCallback)
* @see org.springframework.data.cql.core.CqlOperations#execute(java.lang.String, org.springframework.data.cql.core.PreparedStatementCallback)
*/
@Override
public <T> T execute(String cql, PreparedStatementCallback<T> action) throws DataAccessException {
@@ -406,7 +406,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#execute(org.springframework.cassandra.core.PreparedStatementCreator)
* @see org.springframework.data.cql.core.CqlOperations#execute(org.springframework.data.cql.core.PreparedStatementCreator)
*/
@Override
public boolean execute(PreparedStatementCreator preparedStatementCreator) throws DataAccessException {
@@ -415,7 +415,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#execute(org.springframework.cassandra.core.PreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementCallback)
* @see org.springframework.data.cql.core.CqlOperations#execute(org.springframework.data.cql.core.PreparedStatementCreator, org.springframework.data.cql.core.PreparedStatementCallback)
*/
@Override
public <T> T execute(PreparedStatementCreator preparedStatementCreator, PreparedStatementCallback<T> action)
@@ -441,7 +441,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(org.springframework.cassandra.core.PreparedStatementCreator, org.springframework.cassandra.core.ResultSetExtractor)
* @see org.springframework.data.cql.core.CqlOperations#query(org.springframework.data.cql.core.PreparedStatementCreator, org.springframework.data.cql.core.ResultSetExtractor)
*/
@Override
public <T> T query(PreparedStatementCreator preparedStatementCreator, ResultSetExtractor<T> resultSetExtractor)
@@ -452,7 +452,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(org.springframework.cassandra.core.PreparedStatementCreator, org.springframework.cassandra.core.RowCallbackHandler)
* @see org.springframework.data.cql.core.CqlOperations#query(org.springframework.data.cql.core.PreparedStatementCreator, org.springframework.data.cql.core.RowCallbackHandler)
*/
@Override
public void query(PreparedStatementCreator preparedStatementCreator, RowCallbackHandler rowCallbackHandler)
@@ -463,7 +463,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(org.springframework.cassandra.core.PreparedStatementCreator, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.CqlOperations#query(org.springframework.data.cql.core.PreparedStatementCreator, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> List<T> query(PreparedStatementCreator preparedStatementCreator, RowMapper<T> rowMapper)
@@ -474,7 +474,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(org.springframework.cassandra.core.PreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.ResultSetExtractor)
* @see org.springframework.data.cql.core.CqlOperations#query(org.springframework.data.cql.core.PreparedStatementCreator, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.ResultSetExtractor)
*/
@Override
public <T> T query(PreparedStatementCreator preparedStatementCreator, PreparedStatementBinder preparedStatementBinder,
@@ -510,7 +510,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(org.springframework.cassandra.core.PreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowCallbackHandler)
* @see org.springframework.data.cql.core.CqlOperations#query(org.springframework.data.cql.core.PreparedStatementCreator, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.RowCallbackHandler)
*/
@Override
public void query(PreparedStatementCreator preparedStatementCreator, PreparedStatementBinder preparedStatementBinder,
@@ -521,7 +521,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(org.springframework.cassandra.core.PreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.CqlOperations#query(org.springframework.data.cql.core.PreparedStatementCreator, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> List<T> query(PreparedStatementCreator preparedStatementCreator,
@@ -532,7 +532,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(java.lang.String, org.springframework.cassandra.core.ResultSetExtractor, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#query(java.lang.String, org.springframework.data.cql.core.ResultSetExtractor, java.lang.Object[])
*/
@Override
public <T> T query(String cql, ResultSetExtractor<T> resultSetExtractor, Object... args) throws DataAccessException {
@@ -542,7 +542,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(java.lang.String, org.springframework.cassandra.core.RowCallbackHandler, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#query(java.lang.String, org.springframework.data.cql.core.RowCallbackHandler, java.lang.Object[])
*/
@Override
public void query(String cql, RowCallbackHandler rowCallbackHandler, Object... args) throws DataAccessException {
@@ -552,7 +552,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(java.lang.String, org.springframework.cassandra.core.RowMapper, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#query(java.lang.String, org.springframework.data.cql.core.RowMapper, java.lang.Object[])
*/
@Override
public <T> List<T> query(String cql, RowMapper<T> rowMapper, Object... args) throws DataAccessException {
@@ -561,7 +561,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.ResultSetExtractor)
* @see org.springframework.data.cql.core.CqlOperations#query(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.ResultSetExtractor)
*/
@Override
public <T> T query(String cql, PreparedStatementBinder preparedStatementBinder,
@@ -572,7 +572,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowCallbackHandler)
* @see org.springframework.data.cql.core.CqlOperations#query(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.RowCallbackHandler)
*/
@Override
public void query(String cql, PreparedStatementBinder preparedStatementBinder, RowCallbackHandler rowCallbackHandler)
@@ -583,7 +583,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.CqlOperations#query(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> List<T> query(String cql, PreparedStatementBinder preparedStatementBinder, RowMapper<T> rowMapper)
@@ -594,7 +594,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForList(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#queryForList(java.lang.String, java.lang.Object[])
*/
@Override
public List<Map<String, Object>> queryForList(String cql, Object... args) throws DataAccessException {
@@ -604,7 +604,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForList(java.lang.String, java.lang.Class, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#queryForList(java.lang.String, java.lang.Class, java.lang.Object[])
*/
@Override
public <T> List<T> queryForList(String cql, Class<T> elementType, Object... args) throws DataAccessException {
@@ -614,7 +614,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForMap(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#queryForMap(java.lang.String, java.lang.Object[])
*/
@Override
public Map<String, Object> queryForMap(String cql, Object... args) throws DataAccessException {
@@ -623,7 +623,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForObject(java.lang.String, java.lang.Class, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#queryForObject(java.lang.String, java.lang.Class, java.lang.Object[])
*/
@Override
public <T> T queryForObject(String cql, Class<T> requiredType, Object... args) throws DataAccessException {
@@ -632,7 +632,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForObject(java.lang.String, org.springframework.cassandra.core.RowMapper, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#queryForObject(java.lang.String, org.springframework.data.cql.core.RowMapper, java.lang.Object[])
*/
@Override
public <T> T queryForObject(String cql, RowMapper<T> rowMapper, Object... args) throws DataAccessException {
@@ -642,7 +642,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForResultSet(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#queryForResultSet(java.lang.String, java.lang.Object[])
*/
@Override
public ResultSet queryForResultSet(String cql, Object... args) throws DataAccessException {
@@ -651,7 +651,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#queryForRows(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.CqlOperations#queryForRows(java.lang.String, java.lang.Object[])
*/
@Override
public Iterable<Row> queryForRows(String cql, Object... args) throws DataAccessException {
@@ -660,7 +660,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#describeRing()
* @see org.springframework.data.cql.core.CqlOperations#describeRing()
*/
@Override
public List<RingMember> describeRing() throws DataAccessException {
@@ -669,7 +669,7 @@ public class CqlTemplate extends CqlTemplateSupport implements CqlOperations {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlOperationsNG#describeRing(org.springframework.cassandra.core.HostMapper)
* @see org.springframework.data.cql.core.CqlOperations#describeRing(org.springframework.data.cql.core.HostMapper)
*/
@Override
public <T> Collection<T> describeRing(HostMapper<T> hostMapper) throws DataAccessException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/CqlTemplateSupport.java
View File

@@ -134,7 +134,7 @@ public abstract class CqlTemplateSupport extends CassandraAccessor {
/* (non-Javadoc)
*
@see org.springframework.cassandra.core.ResultSetExtractor#extractData(com.datastax.driver.core.ResultSet)
@see org.springframework.data.cql.core.ResultSetExtractor#extractData(com.datastax.driver.core.ResultSet)
*/
@Override
public Object extractData(ResultSet resultSet) {

86
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/ReactiveCqlTemplate.java
View File

@@ -65,7 +65,7 @@ import com.datastax.driver.core.querybuilder.QueryBuilder;
* it.
* <p>
* All CQL operations performed by this class are logged at debug level, using
* "org.springframework.cassandra.core.ReactiveCqlTemplate" as log category.
* "org.springframework.data.cql.core.ReactiveCqlTemplate" as log category.
* <p>
* <b>NOTE: An instance of this class is thread-safe once configured.</b>
*
@@ -196,11 +196,11 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
// -------------------------------------------------------------------------
// Methods dealing with a plain org.springframework.cassandra.core.ReactiveSession
// Methods dealing with a plain org.springframework.data.cql.core.ReactiveSession
// -------------------------------------------------------------------------
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#execute(org.springframework.cassandra.core.ReactiveSessionCallback)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#execute(org.springframework.data.cql.core.ReactiveSessionCallback)
*/
@Override
public <T> Flux<T> execute(ReactiveSessionCallback<T> action) throws DataAccessException {
@@ -215,7 +215,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
// -------------------------------------------------------------------------
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#execute(java.lang.String)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#execute(java.lang.String)
*/
@Override
public Mono<Boolean> execute(String cql) throws DataAccessException {
@@ -226,7 +226,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.cassandra.core.ReactiveResultSetExtractor)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.data.cql.core.ReactiveResultSetExtractor)
*/
@Override
public <T> Flux<T> query(String cql, ReactiveResultSetExtractor<T> resultSetExtractor) throws DataAccessException {
@@ -245,7 +245,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> Flux<T> query(String cql, RowMapper<T> rowMapper) throws DataAccessException {
@@ -253,7 +253,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForObject(java.lang.String, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForObject(java.lang.String, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> Mono<T> queryForObject(String cql, RowMapper<T> rowMapper) throws DataAccessException {
@@ -262,7 +262,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForObject(java.lang.String, java.lang.Class)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForObject(java.lang.String, java.lang.Class)
*/
@Override
public <T> Mono<T> queryForObject(String cql, Class<T> requiredType) throws DataAccessException {
@@ -270,7 +270,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForMap(java.lang.String)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForMap(java.lang.String)
*/
@Override
public Mono<Map<String, Object>> queryForMap(String cql) throws DataAccessException {
@@ -278,7 +278,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForFlux(java.lang.String, java.lang.Class)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForFlux(java.lang.String, java.lang.Class)
*/
@Override
public <T> Flux<T> queryForFlux(String cql, Class<T> elementType) throws DataAccessException {
@@ -286,7 +286,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForFlux(java.lang.String)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForFlux(java.lang.String)
*/
@Override
public Flux<Map<String, Object>> queryForFlux(String cql) throws DataAccessException {
@@ -294,7 +294,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForResultSet(java.lang.String)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForResultSet(java.lang.String)
*/
@Override
public Mono<ReactiveResultSet> queryForResultSet(String cql) throws DataAccessException {
@@ -312,7 +312,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForRows(java.lang.String)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForRows(java.lang.String)
*/
@Override
public Flux<Row> queryForRows(String cql) throws DataAccessException {
@@ -321,7 +321,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#execute(org.reactivestreams.Publisher)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#execute(org.reactivestreams.Publisher)
*/
@Override
public Flux<Boolean> execute(Publisher<String> statementPublisher) throws DataAccessException {
@@ -336,7 +336,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
// -------------------------------------------------------------------------
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#execute(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#execute(com.datastax.driver.core.Statement)
*/
@Override
public Mono<Boolean> execute(Statement statement) throws DataAccessException {
@@ -347,7 +347,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(com.datastax.driver.core.Statement, org.springframework.cassandra.core.ReactiveResultSetExtractor)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(com.datastax.driver.core.Statement, org.springframework.data.cql.core.ReactiveResultSetExtractor)
*/
@Override
public <T> Flux<T> query(Statement statement, ReactiveResultSetExtractor<T> rse) throws DataAccessException {
@@ -366,7 +366,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(com.datastax.driver.core.Statement, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(com.datastax.driver.core.Statement, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> Flux<T> query(Statement statement, RowMapper<T> rowMapper) throws DataAccessException {
@@ -374,7 +374,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForObject(com.datastax.driver.core.Statement, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForObject(com.datastax.driver.core.Statement, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> Mono<T> queryForObject(Statement statement, RowMapper<T> rowMapper) throws DataAccessException {
@@ -383,7 +383,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForObject(com.datastax.driver.core.Statement, java.lang.Class)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForObject(com.datastax.driver.core.Statement, java.lang.Class)
*/
@Override
public <T> Mono<T> queryForObject(Statement statement, Class<T> requiredType) throws DataAccessException {
@@ -391,7 +391,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForMap(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForMap(com.datastax.driver.core.Statement)
*/
@Override
public Mono<Map<String, Object>> queryForMap(Statement statement) throws DataAccessException {
@@ -399,7 +399,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForFlux(com.datastax.driver.core.Statement, java.lang.Class)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForFlux(com.datastax.driver.core.Statement, java.lang.Class)
*/
@Override
public <T> Flux<T> queryForFlux(Statement statement, Class<T> elementType) throws DataAccessException {
@@ -407,7 +407,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForFlux(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForFlux(com.datastax.driver.core.Statement)
*/
@Override
public Flux<Map<String, Object>> queryForFlux(Statement statement) throws DataAccessException {
@@ -415,7 +415,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForResultSet(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForResultSet(com.datastax.driver.core.Statement)
*/
@Override
public Mono<ReactiveResultSet> queryForResultSet(Statement statement) throws DataAccessException {
@@ -444,7 +444,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
// -------------------------------------------------------------------------
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#execute(org.springframework.cassandra.core.ReactivePreparedStatementCreator, org.springframework.cassandra.core.ReactivePreparedStatementCallback)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#execute(org.springframework.data.cql.core.ReactivePreparedStatementCreator, org.springframework.data.cql.core.ReactivePreparedStatementCallback)
*/
@Override
public <T> Flux<T> execute(ReactivePreparedStatementCreator psc, ReactivePreparedStatementCallback<T> action)
@@ -463,7 +463,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#execute(java.lang.String, org.springframework.cassandra.core.ReactivePreparedStatementCallback)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#execute(java.lang.String, org.springframework.data.cql.core.ReactivePreparedStatementCallback)
*/
@Override
public <T> Flux<T> execute(String cql, ReactivePreparedStatementCallback<T> action) throws DataAccessException {
@@ -502,7 +502,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(org.springframework.cassandra.core.ReactivePreparedStatementCreator, org.springframework.cassandra.core.ReactiveResultSetExtractor)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(org.springframework.data.cql.core.ReactivePreparedStatementCreator, org.springframework.data.cql.core.ReactiveResultSetExtractor)
*/
@Override
public <T> Flux<T> query(ReactivePreparedStatementCreator psc, ReactiveResultSetExtractor<T> rse)
@@ -512,7 +512,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.ReactiveResultSetExtractor)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.ReactiveResultSetExtractor)
*/
@Override
public <T> Flux<T> query(String cql, PreparedStatementBinder psb, ReactiveResultSetExtractor<T> rse)
@@ -522,7 +522,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.cassandra.core.ReactiveResultSetExtractor, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.data.cql.core.ReactiveResultSetExtractor, java.lang.Object[])
*/
@Override
public <T> Flux<T> query(String cql, ReactiveResultSetExtractor<T> rse, Object... args) throws DataAccessException {
@@ -530,7 +530,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(org.springframework.cassandra.core.ReactivePreparedStatementCreator, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(org.springframework.data.cql.core.ReactivePreparedStatementCreator, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> Flux<T> query(ReactivePreparedStatementCreator psc, RowMapper<T> rowMapper) throws DataAccessException {
@@ -538,7 +538,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> Flux<T> query(String cql, PreparedStatementBinder psb, RowMapper<T> rowMapper) throws DataAccessException {
@@ -546,7 +546,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(org.springframework.cassandra.core.ReactivePreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowMapper)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(org.springframework.data.cql.core.ReactivePreparedStatementCreator, org.springframework.data.cql.core.PreparedStatementBinder, org.springframework.data.cql.core.RowMapper)
*/
@Override
public <T> Flux<T> query(ReactivePreparedStatementCreator psc, PreparedStatementBinder psb, RowMapper<T> rowMapper)
@@ -556,7 +556,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.cassandra.core.RowMapper, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveCqlOperations#query(java.lang.String, org.springframework.data.cql.core.RowMapper, java.lang.Object[])
*/
@Override
public <T> Flux<T> query(String cql, RowMapper<T> rowMapper, Object... args) throws DataAccessException {
@@ -564,7 +564,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForObject(java.lang.String, org.springframework.cassandra.core.RowMapper, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForObject(java.lang.String, org.springframework.data.cql.core.RowMapper, java.lang.Object[])
*/
@Override
public <T> Mono<T> queryForObject(String cql, RowMapper<T> rowMapper, Object... args) throws DataAccessException {
@@ -573,7 +573,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForObject(java.lang.String, java.lang.Class, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForObject(java.lang.String, java.lang.Class, java.lang.Object[])
*/
@Override
public <T> Mono<T> queryForObject(String cql, Class<T> requiredType, Object... args) throws DataAccessException {
@@ -581,7 +581,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForMap(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForMap(java.lang.String, java.lang.Object[])
*/
@Override
public Mono<Map<String, Object>> queryForMap(String cql, Object... args) throws DataAccessException {
@@ -589,7 +589,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForFlux(java.lang.String, java.lang.Class, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForFlux(java.lang.String, java.lang.Class, java.lang.Object[])
*/
@Override
public <T> Flux<T> queryForFlux(String cql, Class<T> elementType, Object... args) throws DataAccessException {
@@ -597,7 +597,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForFlux(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForFlux(java.lang.String, java.lang.Object[])
*/
@Override
public Flux<Map<String, Object>> queryForFlux(String cql, Object... args) throws DataAccessException {
@@ -605,7 +605,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForResultSet(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForResultSet(java.lang.String, java.lang.Object[])
*/
@Override
public Mono<ReactiveResultSet> queryForResultSet(String cql, Object... args) throws DataAccessException {
@@ -617,7 +617,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#queryForRows(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveCqlOperations#queryForRows(java.lang.String, java.lang.Object[])
*/
@Override
public Flux<Row> queryForRows(String cql, Object... args) throws DataAccessException {
@@ -626,7 +626,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#execute(org.springframework.cassandra.core.ReactivePreparedStatementCreator)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#execute(org.springframework.data.cql.core.ReactivePreparedStatementCreator)
*/
@Override
public Mono<Boolean> execute(ReactivePreparedStatementCreator psc) throws DataAccessException {
@@ -634,7 +634,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#execute(java.lang.String, org.springframework.cassandra.core.PreparedStatementBinder)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#execute(java.lang.String, org.springframework.data.cql.core.PreparedStatementBinder)
*/
@Override
public Mono<Boolean> execute(String cql, PreparedStatementBinder psb) throws DataAccessException {
@@ -643,7 +643,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#execute(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveCqlOperations#execute(java.lang.String, java.lang.Object[])
*/
@Override
public Mono<Boolean> execute(String cql, Object... args) throws DataAccessException {
@@ -651,7 +651,7 @@ public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements Re
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveCqlOperations#execute(java.lang.String, org.reactivestreams.Publisher)
* @see org.springframework.data.cql.core.ReactiveCqlOperations#execute(java.lang.String, org.reactivestreams.Publisher)
*/
@Override
public Flux<Boolean> execute(String cql, Publisher<Object[]> args) throws DataAccessException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/ReactiveRowMapperResultSetExtractor.java
View File

@@ -56,7 +56,7 @@ public class ReactiveRowMapperResultSetExtractor<T> implements ReactiveResultSet
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveResultSetExtractor#extractData(org.springframework.cassandra.core.ReactiveResultSet)
* @see org.springframework.data.cql.core.ReactiveResultSetExtractor#extractData(org.springframework.data.cql.core.ReactiveResultSet)
*/
@Override
public Publisher<T> extractData(ReactiveResultSet resultSet) throws DriverException, DataAccessException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/RingMemberHostMapper.java
View File

@@ -36,7 +36,7 @@ public enum RingMemberHostMapper implements HostMapper<RingMember> {
INSTANCE;
/* (non-Javadoc)
* @see org.springframework.cassandra.core.HostMapper#mapHosts(java.util.Iterable)
* @see org.springframework.data.cql.core.HostMapper#mapHosts(java.util.Iterable)
*/
@Override
public Collection<RingMember> mapHosts(Iterable<Host> hosts) throws DriverException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/RowMapperResultSetExtractor.java
View File

@@ -70,7 +70,7 @@ public class RowMapperResultSetExtractor<T> implements ResultSetExtractor<List<T
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ResultSetExtractor#extractData(com.datastax.driver.core.ResultSet)
* @see org.springframework.data.cql.core.ResultSetExtractor#extractData(com.datastax.driver.core.ResultSet)
*/
@Override
public List<T> extractData(ResultSet resultSet) throws DriverException, DataAccessException {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/SimplePreparedStatementCreator.java
View File

@@ -48,14 +48,14 @@ public class SimplePreparedStatementCreator implements PreparedStatementCreator,
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.CqlProvider#getCql()
* @see org.springframework.data.cql.core.CqlProvider#getCql()
*/
public String getCql() {
return this.cql;
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.PreparedStatementCreator#createPreparedStatement(com.datastax.driver.core.Session)
* @see org.springframework.data.cql.core.PreparedStatementCreator#createPreparedStatement(com.datastax.driver.core.Session)
*/
@Override
public PreparedStatement createPreparedStatement(Session session) throws DriverException {

14
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/WriteOptions.java
View File

@@ -99,7 +99,7 @@ public class WriteOptions extends QueryOptions {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.QueryOptions.QueryOptionsBuilder#consistencyLevel(com.datastax.driver.core.ConsistencyLevel)
* @see org.springframework.data.cql.core.QueryOptions.QueryOptionsBuilder#consistencyLevel(com.datastax.driver.core.ConsistencyLevel)
*/
@Override
public WriteOptionsBuilder consistencyLevel(com.datastax.driver.core.ConsistencyLevel consistencyLevel) {
@@ -108,7 +108,7 @@ public class WriteOptions extends QueryOptions {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.QueryOptions.QueryOptionsBuilder#retryPolicy(org.springframework.cassandra.core.RetryPolicy)
* @see org.springframework.data.cql.core.QueryOptions.QueryOptionsBuilder#retryPolicy(org.springframework.data.cql.core.RetryPolicy)
*/
@Override
public WriteOptionsBuilder retryPolicy(com.datastax.driver.core.policies.RetryPolicy driverRetryPolicy) {
@@ -117,7 +117,7 @@ public class WriteOptions extends QueryOptions {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.QueryOptions.QueryOptionsBuilder#fetchSize(int)
* @see org.springframework.data.cql.core.QueryOptions.QueryOptionsBuilder#fetchSize(int)
*/
@Override
public WriteOptionsBuilder fetchSize(int fetchSize) {
@@ -126,7 +126,7 @@ public class WriteOptions extends QueryOptions {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.QueryOptions.QueryOptionsBuilder#readTimeout(long)
* @see org.springframework.data.cql.core.QueryOptions.QueryOptionsBuilder#readTimeout(long)
*/
@Override
public WriteOptionsBuilder readTimeout(long readTimeout) {
@@ -135,7 +135,7 @@ public class WriteOptions extends QueryOptions {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.QueryOptions.QueryOptionsBuilder#readTimeout(long, java.util.concurrent.TimeUnit)
* @see org.springframework.data.cql.core.QueryOptions.QueryOptionsBuilder#readTimeout(long, java.util.concurrent.TimeUnit)
*/
@Override
public WriteOptionsBuilder readTimeout(long readTimeout, TimeUnit timeUnit) {
@@ -144,7 +144,7 @@ public class WriteOptions extends QueryOptions {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.QueryOptions.QueryOptionsBuilder#tracing(boolean)
* @see org.springframework.data.cql.core.QueryOptions.QueryOptionsBuilder#tracing(boolean)
*/
@Override
public WriteOptionsBuilder tracing(boolean tracing) {
@@ -153,7 +153,7 @@ public class WriteOptions extends QueryOptions {
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.QueryOptions.QueryOptionsBuilder#withTracing()
* @see org.springframework.data.cql.core.QueryOptions.QueryOptionsBuilder#withTracing()
*/
@Override
public WriteOptionsBuilder withTracing() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToBigDecimalConverter.java
View File

@@ -31,7 +31,7 @@ public class ResultSetToBigDecimalConverter extends AbstractResultSetToBasicFixe
public static final ResultSetToBigDecimalConverter INSTANCE = new ResultSetToBigDecimalConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected BigDecimal doConvertSingleValue(Object object) {
@@ -39,7 +39,7 @@ public class ResultSetToBigDecimalConverter extends AbstractResultSetToBasicFixe
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToBigIntegerConverter.java
View File

@@ -31,7 +31,7 @@ public class ResultSetToBigIntegerConverter extends AbstractResultSetToBasicFixe
public static final ResultSetToBigIntegerConverter INSTANCE = new ResultSetToBigIntegerConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected BigInteger doConvertSingleValue(Object object) {
@@ -39,7 +39,7 @@ public class ResultSetToBigIntegerConverter extends AbstractResultSetToBasicFixe
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToBooleanConverter.java
View File

@@ -29,7 +29,7 @@ public class ResultSetToBooleanConverter extends AbstractResultSetToBasicFixedTy
public static final ResultSetToBooleanConverter INSTANCE = new ResultSetToBooleanConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected Boolean doConvertSingleValue(Object object) {
@@ -37,7 +37,7 @@ public class ResultSetToBooleanConverter extends AbstractResultSetToBasicFixedTy
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToByteBufferConverter.java
View File

@@ -31,7 +31,7 @@ public class ResultSetToByteBufferConverter extends AbstractResultSetConverter<B
public static final ResultSetToByteBufferConverter INSTANCE = new ResultSetToByteBufferConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected ByteBuffer doConvertSingleValue(Object object) {
@@ -44,7 +44,7 @@ public class ResultSetToByteBufferConverter extends AbstractResultSetConverter<B
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToDateConverter.java
View File

@@ -31,7 +31,7 @@ public class ResultSetToDateConverter extends AbstractResultSetToBasicFixedTypeC
public static final ResultSetToDateConverter INSTANCE = new ResultSetToDateConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected Date doConvertSingleValue(Object object) {
@@ -39,7 +39,7 @@ public class ResultSetToDateConverter extends AbstractResultSetToBasicFixedTypeC
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToDoubleConverter.java
View File

@@ -29,7 +29,7 @@ public class ResultSetToDoubleConverter extends AbstractResultSetToBasicFixedTyp
public static final ResultSetToDoubleConverter INSTANCE = new ResultSetToDoubleConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected Double doConvertSingleValue(Object object) {
@@ -37,7 +37,7 @@ public class ResultSetToDoubleConverter extends AbstractResultSetToBasicFixedTyp
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToFloatConverter.java
View File

@@ -29,7 +29,7 @@ public class ResultSetToFloatConverter extends AbstractResultSetToBasicFixedType
public static final ResultSetToFloatConverter INSTANCE = new ResultSetToFloatConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected Float doConvertSingleValue(Object object) {
@@ -37,7 +37,7 @@ public class ResultSetToFloatConverter extends AbstractResultSetToBasicFixedType
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToInetAddressConverter.java
View File

@@ -31,7 +31,7 @@ public class ResultSetToInetAddressConverter extends AbstractResultSetToBasicFix
public static final ResultSetToInetAddressConverter INSTANCE = new ResultSetToInetAddressConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected InetAddress doConvertSingleValue(Object object) {
@@ -39,7 +39,7 @@ public class ResultSetToInetAddressConverter extends AbstractResultSetToBasicFix
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToIntegerConverter.java
View File

@@ -29,7 +29,7 @@ public class ResultSetToIntegerConverter extends AbstractResultSetToBasicFixedTy
public static final ResultSetToIntegerConverter INSTANCE = new ResultSetToIntegerConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected Integer doConvertSingleValue(Object object) {
@@ -37,7 +37,7 @@ public class ResultSetToIntegerConverter extends AbstractResultSetToBasicFixedTy
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToListOfStringConverter.java
View File

@@ -35,7 +35,7 @@ public class ResultSetToListOfStringConverter extends AbstractResultSetConverter
public static final ResultSetToListOfStringConverter INSTANCE = new ResultSetToListOfStringConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected List<String> doConvertSingleValue(Object object) {
@@ -47,7 +47,7 @@ public class ResultSetToListOfStringConverter extends AbstractResultSetConverter
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleRow(java.util.Map)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleRow(java.util.Map)
*/
@Override
protected List<String> doConvertSingleRow(Map<String, Object> row) {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToLongConverter.java
View File

@@ -29,7 +29,7 @@ public class ResultSetToLongConverter extends AbstractResultSetToBasicFixedTypeC
public static final ResultSetToLongConverter INSTANCE = new ResultSetToLongConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected Long doConvertSingleValue(Object object) {
@@ -37,7 +37,7 @@ public class ResultSetToLongConverter extends AbstractResultSetToBasicFixedTypeC
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToStringConverter.java
View File

@@ -32,7 +32,7 @@ public class ResultSetToStringConverter extends AbstractResultSetConverter<Strin
public static final ResultSetToStringConverter INSTANCE = new ResultSetToStringConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected String doConvertSingleValue(Object object) {
@@ -40,7 +40,7 @@ public class ResultSetToStringConverter extends AbstractResultSetConverter<Strin
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleRow(java.util.Map)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleRow(java.util.Map)
*/
@Override
protected String doConvertSingleRow(Map<String, Object> row) {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/converter/ResultSetToUuidConverter.java
View File

@@ -31,7 +31,7 @@ public class ResultSetToUuidConverter extends AbstractResultSetToBasicFixedTypeC
public static final ResultSetToUuidConverter INSTANCE = new ResultSetToUuidConverter();
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#doConvertSingleValue(java.lang.Object)
*/
@Override
protected UUID doConvertSingleValue(Object object) {
@@ -39,7 +39,7 @@ public class ResultSetToUuidConverter extends AbstractResultSetToBasicFixedTypeC
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.converter.AbstractResultSetConverter#getType()
* @see org.springframework.data.cql.core.converter.AbstractResultSetConverter#getType()
*/
@Override
protected Class<?> getType() {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/generator/AddColumnCqlGenerator.java
View File

@@ -35,7 +35,7 @@ public class AddColumnCqlGenerator extends ColumnChangeCqlGenerator<AddColumnSpe
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.cql.generator.ColumnChangeCqlGenerator#toCql(java.lang.StringBuilder)
* @see org.springframework.data.cql.core.cql.generator.ColumnChangeCqlGenerator#toCql(java.lang.StringBuilder)
*/
@Override
public StringBuilder toCql(StringBuilder cql) {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/generator/AlterUserTypeCqlGenerator.java
View File

@@ -52,7 +52,7 @@ public class AlterUserTypeCqlGenerator extends UserTypeNameCqlGenerator<AlterUse
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.cql.generator.UserTypeNameCqlGenerator#toCql(java.lang.StringBuilder)
* @see org.springframework.data.cql.core.cql.generator.UserTypeNameCqlGenerator#toCql(java.lang.StringBuilder)
*/
@Override
public StringBuilder toCql(StringBuilder cql) {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/generator/CreateUserTypeCqlGenerator.java
View File

@@ -46,7 +46,7 @@ public class CreateUserTypeCqlGenerator extends UserTypeNameCqlGenerator<CreateU
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.cql.generator.UserTypeNameCqlGenerator#toCql(java.lang.StringBuilder)
* @see org.springframework.data.cql.core.cql.generator.UserTypeNameCqlGenerator#toCql(java.lang.StringBuilder)
*/
@Override
public StringBuilder toCql(StringBuilder cql) {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/generator/DropUserTypeCqlGenerator.java
View File

@@ -44,7 +44,7 @@ public class DropUserTypeCqlGenerator extends UserTypeNameCqlGenerator<DropUserT
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.cql.generator.UserTypeNameCqlGenerator#toCql(java.lang.StringBuilder)
* @see org.springframework.data.cql.core.cql.generator.UserTypeNameCqlGenerator#toCql(java.lang.StringBuilder)
*/
@Override
public StringBuilder toCql(StringBuilder cql) {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/generator/RenameColumnCqlGenerator.java
View File

@@ -50,7 +50,7 @@ public class RenameColumnCqlGenerator extends ColumnChangeCqlGenerator<RenameCol
/*
* (non-Javadoc)
* @see org.springframework.cassandra.core.cql.generator.ColumnChangeCqlGenerator#toCql(java.lang.StringBuilder)
* @see org.springframework.data.cql.core.cql.generator.ColumnChangeCqlGenerator#toCql(java.lang.StringBuilder)
*/
public StringBuilder toCql(StringBuilder cql) {
return noNull(cql).append(keyword).append(' ').append(spec().getName()).append(" TO ")

8
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/keyspace/CreateIndexSpecification.java
View File

@@ -84,7 +84,7 @@ public class CreateIndexSpecification extends IndexNameSpecification<CreateIndex
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.IndexDescriptor#isCustom()
* @see org.springframework.data.cql.core.keyspace.IndexDescriptor#isCustom()
*/
@Override
public boolean isCustom() {
@@ -105,7 +105,7 @@ public class CreateIndexSpecification extends IndexNameSpecification<CreateIndex
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.IndexDescriptor#getUsing()
* @see org.springframework.data.cql.core.keyspace.IndexDescriptor#getUsing()
*/
@Override
public String getUsing() {
@@ -113,7 +113,7 @@ public class CreateIndexSpecification extends IndexNameSpecification<CreateIndex
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.IndexDescriptor#getColumnName()
* @see org.springframework.data.cql.core.keyspace.IndexDescriptor#getColumnName()
*/
@Override
public CqlIdentifier getColumnName() {
@@ -138,7 +138,7 @@ public class CreateIndexSpecification extends IndexNameSpecification<CreateIndex
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.IndexDescriptor#getTableName()
* @see org.springframework.data.cql.core.keyspace.IndexDescriptor#getTableName()
*/
@Override
public CqlIdentifier getTableName() {

14
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/keyspace/DefaultOption.java
View File

@@ -108,49 +108,49 @@ public class DefaultOption implements Option {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.Option#getType()
* @see org.springframework.data.cql.core.keyspace.Option#getType()
*/
public Class<?> getType() {
return type;
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.Option#getName()
* @see org.springframework.data.cql.core.keyspace.Option#getName()
*/
public String getName() {
return name;
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.Option#takesValue()
* @see org.springframework.data.cql.core.keyspace.Option#takesValue()
*/
public boolean takesValue() {
return type != null;
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.Option#requiresValue()
* @see org.springframework.data.cql.core.keyspace.Option#requiresValue()
*/
public boolean requiresValue() {
return this.requiresValue;
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.Option#escapesValue()
* @see org.springframework.data.cql.core.keyspace.Option#escapesValue()
*/
public boolean escapesValue() {
return this.escapesValue;
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.Option#quotesValue()
* @see org.springframework.data.cql.core.keyspace.Option#quotesValue()
*/
public boolean quotesValue() {
return this.quotesValue;
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.keyspace.Option#checkValue(java.lang.Object)
* @see org.springframework.data.cql.core.keyspace.Option#checkValue(java.lang.Object)
*/
public void checkValue(Object value) {
if (takesValue()) {

30
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/session/DefaultBridgedReactiveSession.java
View File

@@ -44,7 +44,7 @@ import com.google.common.util.concurrent.ListenableFuture;
* this is an intermediate solution until Datastax can provide a fully reactive driver.
* <p>
* All CQL operations performed by this class are logged at debug level, using
* "org.springframework.cassandra.core.DefaultBridgedReactiveSession" as log category.
* "org.springframework.data.cql.core.DefaultBridgedReactiveSession" as log category.
* <p>
*
* @author Mark Paluch
@@ -77,7 +77,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveSession#execute(java.lang.String)
* @see org.springframework.data.cql.core.ReactiveSession#execute(java.lang.String)
*/
@Override
public Mono<ReactiveResultSet> execute(String query) {
@@ -88,7 +88,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveSession#execute(java.lang.String, java.lang.Object[])
* @see org.springframework.data.cql.core.ReactiveSession#execute(java.lang.String, java.lang.Object[])
*/
@Override
public Mono<ReactiveResultSet> execute(String query, Object... values) {
@@ -99,7 +99,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveSession#execute(java.lang.String, java.util.Map)
* @see org.springframework.data.cql.core.ReactiveSession#execute(java.lang.String, java.util.Map)
*/
@Override
public Mono<ReactiveResultSet> execute(String query, Map<String, Object> values) {
@@ -110,7 +110,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveSession#execute(com.datastax.driver.core.Statement)
* @see org.springframework.data.cql.core.ReactiveSession#execute(com.datastax.driver.core.Statement)
*/
@Override
public Mono<ReactiveResultSet> execute(Statement statement) {
@@ -147,7 +147,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveSession#prepare(java.lang.String)
* @see org.springframework.data.cql.core.ReactiveSession#prepare(java.lang.String)
*/
@Override
public Mono<PreparedStatement> prepare(String query) {
@@ -158,7 +158,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveSession#prepare(com.datastax.driver.core.RegularStatement)
* @see org.springframework.data.cql.core.ReactiveSession#prepare(com.datastax.driver.core.RegularStatement)
*/
@Override
public Mono<PreparedStatement> prepare(RegularStatement statement) {
@@ -194,7 +194,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveSession#close()
* @see org.springframework.data.cql.core.ReactiveSession#close()
*/
@Override
public void close() {
@@ -202,7 +202,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveSession#isClosed()
* @see org.springframework.data.cql.core.ReactiveSession#isClosed()
*/
@Override
public boolean isClosed() {
@@ -210,7 +210,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveSession#getCluster()
* @see org.springframework.data.cql.core.ReactiveSession#getCluster()
*/
@Override
public Cluster getCluster() {
@@ -228,7 +228,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveResultSet#rows()
* @see org.springframework.data.cql.core.ReactiveResultSet#rows()
*/
@Override
public Flux<Row> rows() {
@@ -241,7 +241,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveResultSet#getColumnDefinitions()
* @see org.springframework.data.cql.core.ReactiveResultSet#getColumnDefinitions()
*/
@Override
public ColumnDefinitions getColumnDefinitions() {
@@ -249,7 +249,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveResultSet#wasApplied()
* @see org.springframework.data.cql.core.ReactiveResultSet#wasApplied()
*/
@Override
public boolean wasApplied() {
@@ -257,7 +257,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveResultSet#getExecutionInfo()
* @see org.springframework.data.cql.core.ReactiveResultSet#getExecutionInfo()
*/
@Override
public ExecutionInfo getExecutionInfo() {
@@ -265,7 +265,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.ReactiveResultSet#getAllExecutionInfo()
* @see org.springframework.data.cql.core.ReactiveResultSet#getAllExecutionInfo()
*/
@Override
public List<ExecutionInfo> getAllExecutionInfo() {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/session/DefaultSessionFactory.java
View File

@@ -46,7 +46,7 @@ public class DefaultSessionFactory implements SessionFactory {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.session.SessionFactory#getSession()
* @see org.springframework.data.cql.core.session.SessionFactory#getSession()
*/
@Override
public Session getSession() {

4
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/session/lookup/AbstractRoutingSessionFactory.java
View File

@@ -112,7 +112,7 @@ public abstract class AbstractRoutingSessionFactory implements SessionFactory, I
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.session.SessionFactory#getSession()
* @see org.springframework.data.cql.core.session.SessionFactory#getSession()
*/
@Override
public Session getSession() {
@@ -175,7 +175,7 @@ public abstract class AbstractRoutingSessionFactory implements SessionFactory, I
return this.sessionFactoryLookup.getSessionFactory((String) sessionFactory);
} else {
throw new IllegalArgumentException(String
.format("Illegal session factory value. Only [org.springframework.cassandra.core.session.SessionFactory]"
.format("Illegal session factory value. Only [org.springframework.data.cql.core.session.SessionFactory]"
+ " and String supported: %s", sessionFactory));
}
}

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/session/lookup/BeanFactorySessionFactoryLookup.java
View File

@@ -71,7 +71,7 @@ public class BeanFactorySessionFactoryLookup implements SessionFactoryLookup, Be
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.session.lookup.SessionFactoryLookup#getSessionFactory(java.lang.String)
* @see org.springframework.data.cql.core.session.lookup.SessionFactoryLookup#getSessionFactory(java.lang.String)
*/
@Override
public SessionFactory getSessionFactory(String sessionFactoryName) throws SessionFactoryLookupFailureException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/session/lookup/MapSessionFactoryLookup.java
View File

@@ -102,7 +102,7 @@ public class MapSessionFactoryLookup implements SessionFactoryLookup {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.session.lookup.SessionFactoryLookup#getSessionFactory(java.lang.String)
* @see org.springframework.data.cql.core.session.lookup.SessionFactoryLookup#getSessionFactory(java.lang.String)
*/
@Override
public SessionFactory getSessionFactory(String sessionFactoryName) throws SessionFactoryLookupFailureException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/core/session/lookup/SingleSessionFactoryLookup.java
View File

@@ -42,7 +42,7 @@ public class SingleSessionFactoryLookup implements SessionFactoryLookup {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.session.lookup.SessionFactoryLookup#getSessionFactory(java.lang.String)
* @see org.springframework.data.cql.core.session.lookup.SessionFactoryLookup#getSessionFactory(java.lang.String)
*/
@Override
public SessionFactory getSessionFactory(String sessionFactoryName) throws SessionFactoryLookupFailureException {

2
spring-data-cassandra/src/main/java/org/springframework/data/cql/support/CassandraExceptionTranslator.java
View File

@@ -73,7 +73,7 @@ public class CassandraExceptionTranslator implements CqlExceptionTranslator {
}
/* (non-Javadoc)
* @see org.springframework.cassandra.core.support.CQLExceptionTranslator#translate(java.lang.String, java.lang.String, com.datastax.driver.core.exceptions.DriverException)
* @see org.springframework.data.cql.core.support.CQLExceptionTranslator#translate(java.lang.String, java.lang.String, com.datastax.driver.core.exceptions.DriverException)
*/
@Override
public DataAccessException translate(String task, String cql, DriverException exception) {

6
spring-data-cassandra/src/main/resources/org/springframework/data/cassandra/config/spring-cassandra-1.0.xsd
View File

@@ -712,7 +712,7 @@ Defines a CassandraMappingContext for holding rich entity mapping information.
]]></xsd:documentation>
<xsd:appinfo>
<tool:exports
type="org.springframework.data.cassandra.mapping.CassandraMappingContext"/>
type="org.springframework.data.cassandra.core.mapping.CassandraMappingContext"/>
</xsd:appinfo>
</xsd:annotation>
<xsd:complexType>
@@ -746,7 +746,7 @@ Defines a CassandraConverter for getting rich mapping functionality.
use="optional">
<xsd:annotation>
<xsd:documentation
source="org.springframework.data.cassandra.mapping.CassandraMappingContext"><![CDATA[
source="org.springframework.data.cassandra.core.mapping.CassandraMappingContext"><![CDATA[
The reference to a CassandraMappingContext. Will default to 'cassandraMapping'.
]]></xsd:documentation>
</xsd:annotation>
@@ -759,7 +759,7 @@ The reference to a CassandraMappingContext. Will default to 'cassandraMapping'.
<xsd:appinfo>
<tool:annotation kind="ref">
<tool:assignable-to
type="org.springframework.data.cassandra.mapping.CassandraMappingContext"/>
type="org.springframework.data.cassandra.core.mapping.CassandraMappingContext"/>
</tool:annotation>
</xsd:appinfo>
</xsd:annotation>

10
spring-data-cassandra/src/main/resources/org/springframework/data/cassandra/config/spring-cassandra-1.5.xsd
View File

@@ -759,7 +759,7 @@ Defines a CassandraConverter for getting rich mapping functionality.
<xsd:attribute name="mapping-ref" type="mappingContextRef" use="optional">
<xsd:annotation>
<xsd:documentation
source="org.springframework.data.cassandra.mapping.CassandraMappingContext"><![CDATA[
source="org.springframework.data.cassandra.core.mapping.CassandraMappingContext"><![CDATA[
The reference to a CassandraMappingContext. Will default to 'cassandraMapping'.
]]></xsd:documentation>
</xsd:annotation>
@@ -774,7 +774,7 @@ Defines a CassandraMappingContext for holding rich entity mapping information.
]]></xsd:documentation>
<xsd:appinfo>
<tool:exports
type="org.springframework.data.cassandra.mapping.CassandraMappingContext" />
type="org.springframework.data.cassandra.core.mapping.CassandraMappingContext"/>
</xsd:appinfo>
</xsd:annotation>
<xsd:complexType>
@@ -803,7 +803,7 @@ The reference to a UserTypeResolver. UserTypeResolver is required when working w
]]></xsd:documentation>
<xsd:appinfo>
<tool:exports
type="org.springframework.data.cassandra.mapping.UserTypeResolver" />
type="org.springframework.data.cassandra.core.mapping.UserTypeResolver"/>
</xsd:appinfo>
</xsd:annotation>
</xsd:attribute>
@@ -835,7 +835,7 @@ The reference to a CassandraTemplate. Will default to 'cqlTemplate'.
<xsd:annotation>
<xsd:appinfo>
<tool:annotation kind="ref">
<tool:assignable-to type="org.springframework.data.cassandra.convert.CassandraConverter"/>
<tool:assignable-to type="org.springframework.data.cassandra.core.convert.CassandraConverter"/>
</tool:annotation>
</xsd:appinfo>
</xsd:annotation>
@@ -858,7 +858,7 @@ The reference to a CassandraTemplate. Will default to 'cqlTemplate'.
<xsd:annotation>
<xsd:appinfo>
<tool:annotation kind="ref">
<tool:assignable-to type="org.springframework.data.cassandra.mapping.CassandraMappingContext"/>
<tool:assignable-to type="org.springframework.data.cassandra.core.mapping.CassandraMappingContext"/>
</tool:annotation>
</xsd:appinfo>
</xsd:annotation>

2
spring-data-cassandra/src/main/resources/org/springframework/data/cql/config/spring-cql-1.5.xsd
View File

@@ -51,7 +51,7 @@ Defines a CassandraTemplate.
<xsd:appinfo>
<tool:annotation>
<tool:exports
type="org.springframework.cassandra.core.CqlTemplate" />
type="org.springframework.data.cql.core.CqlTemplate"/>
</tool:annotation>
</xsd:appinfo>
</xsd:annotation>

2
spring-data-cassandra/src/test/java/org/springframework/data/cql/core/ReactiveCqlTemplateUnitTests.java
View File

@@ -78,7 +78,7 @@ public class ReactiveCqlTemplateUnitTests {
}
// -------------------------------------------------------------------------
// Tests dealing with a plain org.springframework.cassandra.core.ReactiveSession
// Tests dealing with a plain org.springframework.data.cql.core.ReactiveSession
// -------------------------------------------------------------------------
@Test // DATACASS-335