public interface ReactiveSearchOperations
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Flux<? extends AggregationContainer<?>> |
aggregate(Query query,
Class<?> entityType)
Perform an aggregation specified by the given
query. |
reactor.core.publisher.Flux<? extends AggregationContainer<?>> |
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. |
Query |
idsQuery(List<String> ids)
Creates a
Query to find get all documents with given ids. |
Query |
matchAllQuery()
Creates a
Query to find all documents. |
<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<ReactiveSearchHits<T>> |
searchForHits(Query query,
Class<?> entityType,
Class<T> resultType)
Perform a search and return the
ReactiveSearchHits which contains information about the search results and
which will provide the documents by the ReactiveSearchHits.getSearchHits() method. |
<T> reactor.core.publisher.Mono<ReactiveSearchHits<T>> |
searchForHits(Query query,
Class<?> entityType,
Class<T> resultType,
IndexCoordinates index)
Perform a search and return the
ReactiveSearchHits which contains information about the search results and
which will provide the documents by the ReactiveSearchHits.getSearchHits() method. |
default <T> reactor.core.publisher.Mono<ReactiveSearchHits<T>> |
searchForHits(Query query,
Class<T> entityType)
Perform a search and return the
ReactiveSearchHits which contains information about the search results and
which will provide the documents by the ReactiveSearchHits.getSearchHits() method. |
default <T> reactor.core.publisher.Mono<ReactiveSearchHits<T>> |
searchForHits(Query query,
Class<T> entityType,
IndexCoordinates index)
Perform a search and return the
ReactiveSearchHits which contains information about the search results and
which will provide the documents by the ReactiveSearchHits.getSearchHits() method. |
<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.Mono<Suggest> |
suggest(Query query,
Class<?> entityType)
Does a suggest query.
|
reactor.core.publisher.Mono<Suggest> |
suggest(Query query,
Class<?> entityType,
IndexCoordinates index)
Does a suggest query.
|
reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> |
suggest(org.elasticsearch.search.suggest.SuggestBuilder suggestion,
Class<?> entityType)
Deprecated.
since 4.3, use
suggest(Query, Class) |
reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> |
suggest(org.elasticsearch.search.suggest.SuggestBuilder suggestion,
IndexCoordinates index)
Deprecated.
since 4.3, use
suggest(Query, Class, IndexCoordinates) |
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 - 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 - 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 - 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.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.default <T> reactor.core.publisher.Mono<ReactiveSearchHits<T>> searchForHits(Query query, Class<T> entityType)
ReactiveSearchHits which contains information about the search results and
which will provide the documents by the ReactiveSearchHits.getSearchHits() method.T - the result type classquery - must not be null.entityType - must not be null.Mono emitting the ReactiveSearchHits that contains the search result information<T> reactor.core.publisher.Mono<ReactiveSearchHits<T>> searchForHits(Query query, Class<?> entityType, Class<T> resultType)
ReactiveSearchHits which contains information about the search results and
which will provide the documents by the ReactiveSearchHits.getSearchHits() method.T - the result type classquery - must not be null.entityType - must not be null.resultType - the projection result type.Mono emitting the ReactiveSearchHits that contains the search result informationdefault <T> reactor.core.publisher.Mono<ReactiveSearchHits<T>> searchForHits(Query query, Class<T> entityType, IndexCoordinates index)
ReactiveSearchHits which contains information about the search results and
which will provide the documents by the ReactiveSearchHits.getSearchHits() method.T - the result type classquery - must not be null.entityType - must not be null.index - the target index, must not be nullMono emitting the ReactiveSearchHits that contains the search result information<T> reactor.core.publisher.Mono<ReactiveSearchHits<T>> searchForHits(Query query, Class<?> entityType, Class<T> resultType, IndexCoordinates index)
ReactiveSearchHits which contains information about the search results and
which will provide the documents by the ReactiveSearchHits.getSearchHits() method.T - the result type classquery - must not be null.entityType - must not be null.resultType - the projection result type.index - the target index, must not be nullMono emitting the ReactiveSearchHits that contains the search result informationreactor.core.publisher.Flux<? extends AggregationContainer<?>> 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<? extends AggregationContainer<?>> 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.@Deprecated reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> suggest(org.elasticsearch.search.suggest.SuggestBuilder suggestion, Class<?> entityType)
suggest(Query, Class)suggestion - the queryentityType - must not be null.@Deprecated reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> suggest(org.elasticsearch.search.suggest.SuggestBuilder suggestion, IndexCoordinates index)
suggest(Query, Class, IndexCoordinates)suggestion - the queryindex - the index to run the query againstreactor.core.publisher.Mono<Suggest> suggest(Query query, Class<?> entityType)
query - the Query containing the suggest definition. Must be currently a NativeSearchQuery, must not
be null.entityType - the type of the entities that might be returned for a completion suggestion, must not be
null.reactor.core.publisher.Mono<Suggest> suggest(Query query, Class<?> entityType, IndexCoordinates index)
query - the Query containing the suggest definition. Must be currently a NativeSearchQuery, must not
be null.entityType - the type of the entities that might be returned for a completion suggestion, must not be
null.index - the index to run the query against, must not be null.Query matchAllQuery()
Query to find all documents. Must be implemented by the concrete implementations to provide an
appropriate query using the respective client.Query idsQuery(List<String> ids)
Query to find get all documents with given ids. Must be implemented by the concrete
implementations to provide an appropriate query using the respective client.ids - the list of ids must not be nullCopyright © 2011–2022 Pivotal Software, Inc.. All rights reserved.