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 . |
default <T> reactor.core.publisher.Flux<T> |
find(Query query,
Class<?> entityType,
Class<T> returnType)
Deprecated.
since 4.0, use
search(Query, Class, Class) . |
default <T> reactor.core.publisher.Flux<T> |
find(Query query,
Class<?> entityType,
Class<T> resultType,
IndexCoordinates index)
Deprecated.
since 4.0, use
search(Query, Class, Class, IndexCoordinates) . |
default <T> reactor.core.publisher.Flux<T> |
find(Query query,
Class<T> entityType)
Deprecated.
since 4.0, use
search(Query, Class) . |
default <T> reactor.core.publisher.Flux<T> |
find(Query query,
Class<T> entityType,
IndexCoordinates index)
Deprecated.
since 4.0, use
search(Query, Class, IndexCoordinates) |
<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 . |
@Deprecated default <T> reactor.core.publisher.Flux<T> find(Query query, Class<T> entityType)
search(Query, Class)
.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
.@Deprecated default <T> reactor.core.publisher.Flux<T> find(Query query, Class<?> entityType, Class<T> returnType)
search(Query, Class, Class)
.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
.@Deprecated default <T> reactor.core.publisher.Flux<T> find(Query query, Class<T> entityType, IndexCoordinates index)
search(Query, Class, IndexCoordinates)
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
.@Deprecated default <T> reactor.core.publisher.Flux<T> find(Query query, Class<?> entityType, Class<T> resultType, IndexCoordinates index)
search(Query, Class, Class, IndexCoordinates)
.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 nullFlux
emitting matching entities one by one wrapped in a SearchHit
.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.<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)
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> 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 nullFlux
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
.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.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.