public interface ReactiveSearchOperations
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<org.elasticsearch.search.aggregations.Aggregation> |
aggregate(Query query,
Class<?> entityType)
Perform an aggregation specified by the given
query . |
reactor.core.publisher.Flux<org.elasticsearch.search.aggregations.Aggregation> |
aggregate(Query query,
Class<?> entityType,
IndexCoordinates index)
Perform an aggregation specified by the given
query . |
default reactor.core.publisher.Mono<Long> |
count(Class<?> entityType)
Count the number of documents matching the given
Query . |
reactor.core.publisher.Mono<Long> |
count(Query query,
Class<?> entityType)
Count the number of documents matching the given
Query . |
reactor.core.publisher.Mono<Long> |
count(Query query,
Class<?> entityType,
IndexCoordinates index)
Count the number of documents matching the given
Query . |
<T> reactor.core.publisher.Flux<SearchHit<T>> |
search(Query query,
Class<?> entityType,
Class<T> returnType)
Search the index for entities matching the given
query . |
<T> reactor.core.publisher.Flux<SearchHit<T>> |
search(Query query,
Class<?> entityType,
Class<T> resultType,
IndexCoordinates index)
Search the index for entities matching the given
query . |
default <T> reactor.core.publisher.Flux<SearchHit<T>> |
search(Query query,
Class<T> entityType)
Search the index for entities matching the given
query . |
default <T> reactor.core.publisher.Flux<SearchHit<T>> |
search(Query query,
Class<T> entityType,
IndexCoordinates index)
Search the index for entities matching the given
query . |
<T> reactor.core.publisher.Mono<SearchPage<T>> |
searchForPage(Query query,
Class<?> entityType,
Class<T> resultType)
Search the index for entities matching the given
query . |
<T> reactor.core.publisher.Mono<SearchPage<T>> |
searchForPage(Query query,
Class<?> entityType,
Class<T> resultType,
IndexCoordinates index)
Search the index for entities matching the given
query . |
default <T> reactor.core.publisher.Mono<SearchPage<T>> |
searchForPage(Query query,
Class<T> entityType)
Search the index for entities matching the given
query . |
default <T> reactor.core.publisher.Mono<SearchPage<T>> |
searchForPage(Query query,
Class<T> entityType,
IndexCoordinates index)
Search the index for entities matching the given
query . |
reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> |
suggest(org.elasticsearch.search.suggest.SuggestBuilder suggestion,
Class<?> entityType)
Does a suggest query
|
reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> |
suggest(org.elasticsearch.search.suggest.SuggestBuilder suggestion,
IndexCoordinates index)
Does a suggest query
|
default reactor.core.publisher.Mono<Long> count(Class<?> entityType)
Query
.entityType
- must not be null.Mono
emitting the nr of matching documents.reactor.core.publisher.Mono<Long> count(Query query, Class<?> entityType)
Query
.query
- must not be null.entityType
- must not be null.Mono
emitting the nr of matching documents.reactor.core.publisher.Mono<Long> count(Query query, Class<?> entityType, IndexCoordinates index)
Query
.query
- must not be null.entityType
- must not be null.index
- the target index, must not be nullMono
emitting the nr of matching documents.default <T> reactor.core.publisher.Flux<SearchHit<T>> search(Query query, Class<T> entityType)
query
. Unpaged
queries may overrule elasticsearch server defaults for page size by either
delegating to the scroll API or using a max size
.T
- query
- must not be null.entityType
- must not be null.Flux
emitting matching entities one by one wrapped in a SearchHit
.<T> reactor.core.publisher.Flux<SearchHit<T>> search(Query query, Class<?> entityType, Class<T> returnType)
query
. Unpaged
queries may overrule elasticsearch server defaults for page size by either *
delegating to the scroll API or using a max *
size
.T
- query
- must not be null.entityType
- The entity type for mapping the query. Must not be null.returnType
- The mapping target type. Must not be null. ThFlux
emitting matching entities one by one wrapped in a SearchHit
.default <T> reactor.core.publisher.Flux<SearchHit<T>> search(Query query, Class<T> entityType, IndexCoordinates index)
query
.T
- query
- must not be null.entityType
- must not be null.index
- the target index, must not be nullFlux
emitting matching entities one by one wrapped in a SearchHit
.<T> reactor.core.publisher.Flux<SearchHit<T>> search(Query query, Class<?> entityType, Class<T> resultType, IndexCoordinates index)
query
.T
- query
- must not be null.entityType
- must not be null.resultType
- the projection result type.index
- the target index, must not be nullFlux
emitting matching entities one by one wrapped in a SearchHit
.default <T> reactor.core.publisher.Mono<SearchPage<T>> searchForPage(Query query, Class<T> entityType)
query
.T
- T
- query
- must not be null.entityType
- must not be null.Mono
emitting matching entities in a SearchHits
.<T> reactor.core.publisher.Mono<SearchPage<T>> searchForPage(Query query, Class<?> entityType, Class<T> resultType)
query
.T
- T
- query
- must not be null.entityType
- must not be null.resultType
- the projection result type.Mono
emitting matching entities in a SearchHits
.default <T> reactor.core.publisher.Mono<SearchPage<T>> searchForPage(Query query, Class<T> entityType, IndexCoordinates index)
query
.T
- T
- query
- must not be null.entityType
- must not be null.index
- the target index, must not be nullMono
emitting matching entities in a SearchHits
.<T> reactor.core.publisher.Mono<SearchPage<T>> searchForPage(Query query, Class<?> entityType, Class<T> resultType, IndexCoordinates index)
query
.T
- T
- query
- must not be null.entityType
- must not be null.resultType
- the projection result type.index
- the target index, must not be nullMono
emitting matching entities in a SearchHits
.reactor.core.publisher.Flux<org.elasticsearch.search.aggregations.Aggregation> aggregate(Query query, Class<?> entityType)
query
. query
- must not be null.entityType
- must not be null.Flux
emitting matching aggregations one by one.reactor.core.publisher.Flux<org.elasticsearch.search.aggregations.Aggregation> aggregate(Query query, Class<?> entityType, IndexCoordinates index)
query
. query
- must not be null.entityType
- must not be null.index
- the target index, must not be nullFlux
emitting matching aggregations one by one.reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> suggest(org.elasticsearch.search.suggest.SuggestBuilder suggestion, Class<?> entityType)
suggestion
- the queryentityType
- must not be null.reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> suggest(org.elasticsearch.search.suggest.SuggestBuilder suggestion, IndexCoordinates index)
suggestion
- the queryindex
- the index to run the query againstCopyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.