Class SimpleReactiveElasticsearchRepository<T,ID>
java.lang.Object
org.springframework.data.elasticsearch.repository.support.SimpleReactiveElasticsearchRepository<T,ID>
- All Implemented Interfaces:
ReactiveElasticsearchRepository<T,
,ID> ReactiveCrudRepository<T,
,ID> ReactiveSortingRepository<T,
,ID> Repository<T,
ID>
public class SimpleReactiveElasticsearchRepository<T,ID>
extends Object
implements ReactiveElasticsearchRepository<T,ID>
- Since:
- 3.2
- Author:
- Christoph Strobl, Peter-Josef Meisch, Aleksei Arsenev, Jens Schauder
-
Constructor Summary
ConstructorsConstructorDescriptionSimpleReactiveElasticsearchRepository
(ElasticsearchEntityInformation<T, ID> entityInformation, ReactiveElasticsearchOperations operations) -
Method Summary
Modifier and TypeMethodDescriptioncount()
void
delete
(T entity, RefreshPolicy refreshPolicy) deleteAll
(Iterable<? extends T> entities, RefreshPolicy refreshPolicy) deleteAll
(Publisher<? extends T> entityStream, RefreshPolicy refreshPolicy) deleteAll
(RefreshPolicy refreshPolicy) deleteAllById
(Iterable<? extends ID> ids) deleteAllById
(Iterable<? extends ID> ids, RefreshPolicy refreshPolicy) deleteById
(ID id) deleteById
(ID id, RefreshPolicy refreshPolicy) deleteById
(Publisher<ID> id) deleteById
(Publisher<ID> id, RefreshPolicy refreshPolicy) existsById
(ID id) existsById
(Publisher<ID> id) findAll()
findAllById
(Iterable<ID> ids) findAllById
(Publisher<ID> idStream) save
(S entity) save
(S entity, RefreshPolicy refreshPolicy) saveAll
(Iterable<S> entities, RefreshPolicy refreshPolicy) saveAll
(Publisher<S> entityStream, RefreshPolicy refreshPolicy)
-
Constructor Details
-
SimpleReactiveElasticsearchRepository
public SimpleReactiveElasticsearchRepository(ElasticsearchEntityInformation<T, ID> entityInformation, ReactiveElasticsearchOperations operations)
-
-
Method Details
-
createIndexAndMappingIfNeeded
public void createIndexAndMappingIfNeeded() -
save
- Specified by:
save
in interfaceReactiveCrudRepository<T,
ID>
-
save
- Specified by:
save
in interfaceReactiveElasticsearchRepository<T,
ID>
-
saveAll
- Specified by:
saveAll
in interfaceReactiveCrudRepository<T,
ID>
-
saveAll
- Specified by:
saveAll
in interfaceReactiveElasticsearchRepository<T,
ID>
-
saveAll
- Specified by:
saveAll
in interfaceReactiveCrudRepository<T,
ID>
-
saveAll
public <S extends T> Flux<S> saveAll(Publisher<S> entityStream, @Nullable RefreshPolicy refreshPolicy) - Specified by:
saveAll
in interfaceReactiveElasticsearchRepository<T,
ID>
-
findById
- Specified by:
findById
in interfaceReactiveCrudRepository<T,
ID>
-
findById
- Specified by:
findById
in interfaceReactiveCrudRepository<T,
ID>
-
existsById
- Specified by:
existsById
in interfaceReactiveCrudRepository<T,
ID>
-
existsById
- Specified by:
existsById
in interfaceReactiveCrudRepository<T,
ID>
-
findAll
- Specified by:
findAll
in interfaceReactiveCrudRepository<T,
ID>
-
findAll
- Specified by:
findAll
in interfaceReactiveSortingRepository<T,
ID>
-
findAllById
- Specified by:
findAllById
in interfaceReactiveCrudRepository<T,
ID>
-
findAllById
- Specified by:
findAllById
in interfaceReactiveCrudRepository<T,
ID>
-
count
- Specified by:
count
in interfaceReactiveCrudRepository<T,
ID>
-
deleteById
- Specified by:
deleteById
in interfaceReactiveCrudRepository<T,
ID>
-
deleteById
- Specified by:
deleteById
in interfaceReactiveElasticsearchRepository<T,
ID>
-
deleteById
- Specified by:
deleteById
in interfaceReactiveCrudRepository<T,
ID>
-
deleteById
- Specified by:
deleteById
in interfaceReactiveElasticsearchRepository<T,
ID>
-
delete
- Specified by:
delete
in interfaceReactiveCrudRepository<T,
ID>
-
delete
- Specified by:
delete
in interfaceReactiveElasticsearchRepository<T,
ID>
-
deleteAllById
- Specified by:
deleteAllById
in interfaceReactiveCrudRepository<T,
ID>
-
deleteAllById
- Specified by:
deleteAllById
in interfaceReactiveElasticsearchRepository<T,
ID>
-
deleteAll
- Specified by:
deleteAll
in interfaceReactiveCrudRepository<T,
ID>
-
deleteAll
- Specified by:
deleteAll
in interfaceReactiveElasticsearchRepository<T,
ID>
-
deleteAll
- Specified by:
deleteAll
in interfaceReactiveCrudRepository<T,
ID>
-
deleteAll
public Mono<Void> deleteAll(Publisher<? extends T> entityStream, @Nullable RefreshPolicy refreshPolicy) - Specified by:
deleteAll
in interfaceReactiveElasticsearchRepository<T,
ID>
-
deleteAll
- Specified by:
deleteAll
in interfaceReactiveCrudRepository<T,
ID>
-
deleteAll
- Specified by:
deleteAll
in interfaceReactiveElasticsearchRepository<T,
ID>
-