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 Details

    • insert

      <S extends T> reactor.core.publisher.Mono<S> insert(S entity)
      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 using ReactiveCrudRepository.save(Object) instead to avoid the usage of store-specific API.
      Parameters:
      entity - must not be null.
      Returns:
      the saved entity
    • insert

      <S extends T> reactor.core.publisher.Flux<S> insert(Iterable<S> entities)
      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 using ReactiveCrudRepository.save(Object) instead to avoid the usage of store-specific API.
      Parameters:
      entities - must not be null.
      Returns:
      the saved entity
    • insert

      <S extends T> reactor.core.publisher.Flux<S> insert(org.reactivestreams.Publisher<S> entities)
      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 using ReactiveCrudRepository.save(Object) instead to avoid the usage of store-specific API.
      Parameters:
      entities - must not be null.
      Returns:
      the saved entity
    • findAllById

      reactor.core.publisher.Flux<T> findAllById(Iterable<ID> iterable)

      Note: Cassandra supports single-field IN queries only. Fetches each row individually when using MapId with multiple components.

      Specified by:
      findAllById in interface ReactiveCrudRepository<T,ID>
    • findAllById

      reactor.core.publisher.Flux<T> findAllById(org.reactivestreams.Publisher<ID> publisher)

      Fetches each row individually.

      Specified by:
      findAllById in interface ReactiveCrudRepository<T,ID>