Interface ReactiveCassandraRepository<T,ID>
- All Superinterfaces:
ReactiveCrudRepository<T,
,ID> Repository<T,
ID>
- All Known Implementing Classes:
SimpleReactiveCassandraRepository
@NoRepositoryBean
public interface ReactiveCassandraRepository<T,ID>
extends ReactiveCrudRepository<T,ID>
Cassandra specific
Repository
interface with reactive support.- Since:
- 2.0
- Author:
- Mark Paluch
-
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<T>
findAllById
(Iterable<ID> iterable) reactor.core.publisher.Flux<T>
findAllById
(org.reactivestreams.Publisher<ID> publisher) <S extends T>
reactor.core.publisher.Flux<S>Inserts the given entities.<S extends T>
reactor.core.publisher.Flux<S>insert
(org.reactivestreams.Publisher<S> entities) Inserts the given a given entities.<S extends T>
reactor.core.publisher.Mono<S>insert
(S entity) Inserts the given entity.Methods inherited from interface org.springframework.data.repository.reactive.ReactiveCrudRepository
count, delete, deleteAll, deleteAll, deleteAll, deleteAllById, deleteById, deleteById, existsById, existsById, findAll, findById, findById, save, saveAll, saveAll
-
Method Details
-
insert
Inserts the given entity. Assumes the instance to be new to be able to apply insertion optimizations. Use the returned instance for further operations as the save operation might have changed the entity instance completely. Prefer usingReactiveCrudRepository.save(Object)
instead to avoid the usage of store-specific API.- Parameters:
entity
- must not be null.- Returns:
- the saved entity
-
insert
Inserts the given entities. Assumes the instance to be new to be able to apply insertion optimizations. Use the returned instance for further operations as the save operation might have changed the entity instance completely. Prefer usingReactiveCrudRepository.save(Object)
instead to avoid the usage of store-specific API.- Parameters:
entities
- must not be null.- Returns:
- the saved entity
-
insert
Inserts the given a given entities. Assumes the instance to be new to be able to apply insertion optimizations. Use the returned instance for further operations as the save operation might have changed the entity instance completely. Prefer usingReactiveCrudRepository.save(Object)
instead to avoid the usage of store-specific API.- Parameters:
entities
- must not be null.- Returns:
- the saved entity
-
findAllById
Note: Cassandra supports single-field
IN
queries only. Fetches each row individually when usingMapId
with multiple components.- Specified by:
findAllById
in interfaceReactiveCrudRepository<T,
ID>
-
findAllById
Fetches each row individually.
- Specified by:
findAllById
in interfaceReactiveCrudRepository<T,
ID>
-