Class ReactiveElasticsearchTemplate
java.lang.Object
org.springframework.data.elasticsearch.core.AbstractReactiveElasticsearchTemplate
org.springframework.data.elasticsearch.client.erhlc.ReactiveElasticsearchTemplate
- All Implemented Interfaces:
Aware
,ApplicationContextAware
,ReactiveDocumentOperations
,ReactiveElasticsearchOperations
,ReactiveSearchOperations
,ReactiveScriptOperations
@Deprecated
public class ReactiveElasticsearchTemplate
extends AbstractReactiveElasticsearchTemplate
Deprecated.
since 5.0
- Since:
- 3.2
- Author:
- Christoph Strobl, Mark Paluch, Farid Azaza, Martin Choraine, Peter-Josef Meisch, Mathias Teier, Aleksei Arsenev, Roman Puchkovskiy, Russell Parry, Thomas Geese, Farid Faoudi, Sijia Liu
-
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.data.elasticsearch.core.AbstractReactiveElasticsearchTemplate
AbstractReactiveElasticsearchTemplate.DocumentCallback<T>, AbstractReactiveElasticsearchTemplate.Entities<T>, AbstractReactiveElasticsearchTemplate.IndexResponseMetaData, AbstractReactiveElasticsearchTemplate.ReadDocumentCallback<T>, AbstractReactiveElasticsearchTemplate.ReadSearchDocumentCallback<T>, AbstractReactiveElasticsearchTemplate.SearchDocumentCallback<T>
Nested classes/interfaces inherited from interface org.springframework.data.elasticsearch.core.ReactiveElasticsearchOperations
ReactiveElasticsearchOperations.ClientCallback<T extends org.reactivestreams.Publisher<?>>, ReactiveElasticsearchOperations.ClusterClientCallback<T extends org.reactivestreams.Publisher<?>>, ReactiveElasticsearchOperations.IndicesClientCallback<T extends org.reactivestreams.Publisher<?>>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected org.springframework.data.elasticsearch.client.erhlc.RequestFactory
Deprecated.Fields inherited from class org.springframework.data.elasticsearch.core.AbstractReactiveElasticsearchTemplate
converter, entityCallbacks, entityOperations, mappingContext, QUERY_LOGGER, refreshPolicy, routingResolver
Fields inherited from interface org.springframework.data.elasticsearch.core.ReactiveDocumentOperations
FLUX_SAVE_BULK_SIZE
-
Constructor Summary
ConstructorsConstructorDescriptionDeprecated.ReactiveElasticsearchTemplate
(ReactiveElasticsearchClient client, ElasticsearchConverter converter) Deprecated. -
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<AggregationContainer<?>>
aggregate
(Query query, Class<?> entityType, IndexCoordinates index) Deprecated.Perform an aggregation specified by the givenquery
.reactor.core.publisher.Mono<Void>
bulkUpdate
(List<UpdateQuery> queries, BulkOptions bulkOptions, IndexCoordinates index) Deprecated.Bulk update all objects.protected reactor.core.publisher.Mono<org.elasticsearch.action.bulk.BulkResponse>
checkForBulkOperationFailure
(org.elasticsearch.action.bulk.BulkResponse bulkResponse) Deprecated.cluster()
Deprecated.return aReactiveClusterOperations
instance that uses the same client communication setup as this ElasticsearchOperations instance.reactor.core.publisher.Mono<ByQueryResponse>
delete
(Query query, Class<?> entityType, IndexCoordinates index) Deprecated.Delete the documents matching the givenQuery
extracting index from entity metadata.protected reactor.core.publisher.Flux<AggregationContainer<?>>
doAggregate
(org.elasticsearch.action.search.SearchRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.protected reactor.core.publisher.Flux<org.elasticsearch.action.bulk.BulkItemResponse>
doBulkOperation
(List<?> queries, BulkOptions bulkOptions, IndexCoordinates index) Deprecated.protected ReactiveElasticsearchTemplate
doCopy()
Deprecated.protected reactor.core.publisher.Mono<Long>
doCount
(org.elasticsearch.action.search.SearchRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.protected reactor.core.publisher.Mono<Long>
doCount
(Query query, Class<?> entityType, IndexCoordinates index) Deprecated.protected reactor.core.publisher.Mono<String>
doDelete
(org.elasticsearch.action.delete.DeleteRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.protected reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse>
doDeleteBy
(org.elasticsearch.index.reindex.DeleteByQueryRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.protected reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse>
doDeleteBy
(Query query, Class<?> entityType, IndexCoordinates index) Deprecated.protected reactor.core.publisher.Mono<String>
doDeleteById
(String id, String routing, IndexCoordinates index) Deprecated.protected reactor.core.publisher.Mono<Boolean>
doExists
(String id, IndexCoordinates index) Deprecated.protected reactor.core.publisher.Mono<Boolean>
doExists
(org.elasticsearch.action.get.GetRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.protected reactor.core.publisher.Flux<SearchDocument>
doFind
(org.elasticsearch.action.search.SearchRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.protected reactor.core.publisher.Flux<SearchDocument>
doFind
(Query query, Class<?> clazz, IndexCoordinates index) Deprecated.protected <T> reactor.core.publisher.Mono<SearchDocumentResponse>
doFindForResponse
(org.elasticsearch.action.search.SearchRequest request, SearchDocumentResponse.EntityCreator<T> entityCreator) Deprecated.Customization hook on the actual execution resultMono
.protected <T> reactor.core.publisher.Mono<SearchDocumentResponse>
doFindForResponse
(Query query, Class<?> clazz, IndexCoordinates index) Deprecated.protected reactor.core.publisher.Mono<org.elasticsearch.index.get.GetResult>
doGet
(org.elasticsearch.action.get.GetRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.protected reactor.core.publisher.Mono<org.elasticsearch.action.index.IndexResponse>
doIndex
(org.elasticsearch.action.index.IndexRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.protected <T> reactor.core.publisher.Mono<reactor.util.function.Tuple2<T,
AbstractReactiveElasticsearchTemplate.IndexResponseMetaData>> doIndex
(T entity, IndexCoordinates index) Deprecated.protected reactor.core.publisher.Flux<SearchDocument>
doScroll
(org.elasticsearch.action.search.SearchRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.<T> org.reactivestreams.Publisher<T>
execute
(ReactiveElasticsearchOperations.ClientCallback<org.reactivestreams.Publisher<T>> callback) Deprecated.Execute within aReactiveElasticsearchOperations.ClientCallback
managing resources and translating errors.<T> org.reactivestreams.Publisher<T>
executeWithClusterClient
(ReactiveElasticsearchOperations.ClusterClientCallback<org.reactivestreams.Publisher<T>> callback) Deprecated.Execute within aReactiveElasticsearchOperations.ClusterClientCallback
managing resources and translating errors.<T> org.reactivestreams.Publisher<T>
executeWithIndicesClient
(ReactiveElasticsearchOperations.IndicesClientCallback<org.reactivestreams.Publisher<T>> callback) Deprecated.Execute within aReactiveElasticsearchOperations.IndicesClientCallback
managing resources and translating errors.<T> reactor.core.publisher.Mono<T>
get
(String id, Class<T> entityType, IndexCoordinates index) Deprecated.Fetch the entity with given id.protected ReactiveElasticsearchClient
Deprecated.Obtain theReactiveElasticsearchClient
to operate upon.protected ReactiveElasticsearchClient.Cluster
Deprecated.Obtain theReactiveElasticsearchClient.Cluster
to operate upon.reactor.core.publisher.Mono<String>
Deprecated.protected ReactiveElasticsearchClient.Indices
Deprecated.Obtain theReactiveElasticsearchClient.Indices
to operate upon.reactor.core.publisher.Mono<String>
Deprecated.reactor.core.publisher.Mono<String>
Deprecated.Deprecated.Creates aQuery
to find get all documents with given ids.Deprecated.Creates aReactiveIndexOperations
that is bound to the given classindexOps
(IndexCoordinates index) Deprecated.Creates aReactiveIndexOperations
that is bound to the given indexDeprecated.Creates aQuery
to find all documents.<T> reactor.core.publisher.Flux<MultiGetItem<T>>
multiGet
(Query query, Class<T> clazz, IndexCoordinates index) Deprecated.Execute a multiGet against elasticsearch for the given ids.protected org.elasticsearch.index.reindex.DeleteByQueryRequest
prepareDeleteByRequest
(org.elasticsearch.index.reindex.DeleteByQueryRequest request) Deprecated.Customization hook to modify a generatedDeleteByQueryRequest
prior to its execution.protected org.elasticsearch.action.delete.DeleteRequest
prepareDeleteRequest
(org.elasticsearch.action.delete.DeleteRequest request) Deprecated.Customization hook to modify a generatedDeleteRequest
prior to its execution.protected org.elasticsearch.action.index.IndexRequest
prepareIndexRequest
(Object source, org.elasticsearch.action.index.IndexRequest request) Deprecated.Customization hook to modify a generatedIndexRequest
prior to its execution.protected org.elasticsearch.action.search.SearchRequest
prepareSearchRequest
(org.elasticsearch.action.search.SearchRequest request, boolean useScroll) Deprecated.Customization hook to modify a generatedSearchRequest
prior to its execution.protected <R extends org.elasticsearch.action.support.WriteRequest<R>>
RprepareWriteRequest
(R request) Deprecated.Preprocess the write request before it is sent to the server, e.g. by setting therefresh policy
if applicable.reactor.core.publisher.Mono<ReindexResponse>
reindex
(ReindexRequest postReindexRequest) Deprecated.Copies documents from a source to a destination.<T> reactor.core.publisher.Flux<T>
saveAll
(reactor.core.publisher.Mono<? extends Collection<? extends T>> entitiesPublisher, IndexCoordinates index) Deprecated.Index entities in the given index.<T> reactor.core.publisher.Mono<SearchPage<T>>
searchForPage
(Query query, Class<?> entityType, Class<T> resultType) Deprecated.Search the index for entities matching the givenquery
.<T> reactor.core.publisher.Mono<SearchPage<T>>
searchForPage
(Query query, Class<?> entityType, Class<T> resultType, IndexCoordinates index) Deprecated.Search the index for entities matching the givenquery
.void
setIndicesOptions
(org.elasticsearch.action.support.IndicesOptions indicesOptions) Deprecated.Set the defaultIndicesOptions
forsearch requests
.reactor.core.publisher.Mono<String>
submitReindex
(ReindexRequest postReindexRequest) Deprecated.Submits a reindex task.reactor.core.publisher.Mono<UpdateResponse>
update
(UpdateQuery updateQuery, IndexCoordinates index) Deprecated.Partial update of the document.reactor.core.publisher.Mono<ByQueryResponse>
updateByQuery
(UpdateQuery updateQuery, IndexCoordinates index) Deprecated.Update document(s) by query.Methods inherited from class org.springframework.data.elasticsearch.core.AbstractReactiveElasticsearchTemplate
aggregate, closePointInTime, count, count, delete, delete, delete, delete, delete, deleteScript, exists, exists, get, getElasticsearchConverter, getIndexCoordinatesFor, getIndexQuery, getPersistentEntityFor, getRefreshPolicy, getScript, logVersions, maybeCallbackAfterConvert, maybeCallbackAfterLoad, maybeCallbackAfterSave, maybeCallbackBeforeConvert, multiGet, openPointInTime, putScript, save, save, save, save, saveAll, search, search, searchForHits, searchForHits, setApplicationContext, setEntityCallbacks, setRefreshPolicy, suggest, suggest, updateIndexedObject, withRouting
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.data.elasticsearch.core.ReactiveDocumentOperations
bulkUpdate, save, save, save, save, saveAll, saveAll
Methods inherited from interface org.springframework.data.elasticsearch.core.ReactiveSearchOperations
count, openPointInTime, search, search, searchForHits, searchForHits, searchForPage, searchForPage
-
Field Details
-
requestFactory
protected org.springframework.data.elasticsearch.client.erhlc.RequestFactory requestFactoryDeprecated.
-
-
Constructor Details
-
ReactiveElasticsearchTemplate
Deprecated. -
ReactiveElasticsearchTemplate
public ReactiveElasticsearchTemplate(ReactiveElasticsearchClient client, @Nullable ElasticsearchConverter converter) Deprecated.
-
-
Method Details
-
doCopy
Deprecated.- Specified by:
doCopy
in classAbstractReactiveElasticsearchTemplate
-
setIndicesOptions
public void setIndicesOptions(@Nullable org.elasticsearch.action.support.IndicesOptions indicesOptions) Deprecated.Set the defaultIndicesOptions
forsearch requests
.- Parameters:
indicesOptions
- can be null.
-
saveAll
public <T> reactor.core.publisher.Flux<T> saveAll(reactor.core.publisher.Mono<? extends Collection<? extends T>> entitiesPublisher, IndexCoordinates index) Deprecated.Description copied from interface:ReactiveDocumentOperations
Index entities in the given index. If the index is null or empty the index name provided via entity metadata is used.- Parameters:
entitiesPublisher
- must not be null.index
- the target index, must not be null- Returns:
- a
Flux
emitting saved entities.
-
multiGet
public <T> reactor.core.publisher.Flux<MultiGetItem<T>> multiGet(Query query, Class<T> clazz, IndexCoordinates index) Deprecated.Description copied from interface:ReactiveDocumentOperations
Execute a multiGet against elasticsearch for the given ids.- Parameters:
query
- the query defining the ids of the objects to getclazz
- the type of the object to be returnedindex
- the index(es) from which the objects are read.- Returns:
- flux with list of
MultiGetItem
s that contain the entities - See Also:
-
doIndex
protected reactor.core.publisher.Mono<org.elasticsearch.action.index.IndexResponse> doIndex(org.elasticsearch.action.index.IndexRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.
You know what you're doing here? Well fair enough, go ahead on your own risk.- Parameters:
request
- the already preparedIndexRequest
ready to be executed.- Returns:
- a
Mono
emitting the result of the operation.
-
bulkUpdate
public reactor.core.publisher.Mono<Void> bulkUpdate(List<UpdateQuery> queries, BulkOptions bulkOptions, IndexCoordinates index) Deprecated.Description copied from interface:ReactiveDocumentOperations
Bulk update all objects. Will do update.- Parameters:
queries
- the queries to execute in bulkbulkOptions
- options to be added to the bulk request
-
doBulkOperation
protected reactor.core.publisher.Flux<org.elasticsearch.action.bulk.BulkItemResponse> doBulkOperation(List<?> queries, BulkOptions bulkOptions, IndexCoordinates index) Deprecated. -
checkForBulkOperationFailure
protected reactor.core.publisher.Mono<org.elasticsearch.action.bulk.BulkResponse> checkForBulkOperationFailure(org.elasticsearch.action.bulk.BulkResponse bulkResponse) Deprecated. -
doExists
Deprecated.- Specified by:
doExists
in classAbstractReactiveElasticsearchTemplate
-
doExists
protected reactor.core.publisher.Mono<Boolean> doExists(org.elasticsearch.action.get.GetRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.- Parameters:
request
- the already preparedGetRequest
ready to be executed.- Returns:
- a
Mono
emitting the result of the operation.
-
doIndex
protected <T> reactor.core.publisher.Mono<reactor.util.function.Tuple2<T,AbstractReactiveElasticsearchTemplate.IndexResponseMetaData>> doIndex(T entity, IndexCoordinates index) Deprecated.- Specified by:
doIndex
in classAbstractReactiveElasticsearchTemplate
-
get
public <T> reactor.core.publisher.Mono<T> get(String id, Class<T> entityType, IndexCoordinates index) Deprecated.Description copied from interface:ReactiveDocumentOperations
Fetch the entity with given id.- Parameters:
id
- must not be null.index
- the target index, must not be null- Returns:
- the
Mono
emitting the entity or signalling completion if none found.
-
doGet
protected reactor.core.publisher.Mono<org.elasticsearch.index.get.GetResult> doGet(org.elasticsearch.action.get.GetRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.- Parameters:
request
- the already preparedGetRequest
ready to be executed.- Returns:
- a
Mono
emitting the result of the operation.
-
doDeleteById
protected reactor.core.publisher.Mono<String> doDeleteById(String id, @Nullable String routing, IndexCoordinates index) Deprecated.- Specified by:
doDeleteById
in classAbstractReactiveElasticsearchTemplate
-
delete
public reactor.core.publisher.Mono<ByQueryResponse> delete(Query query, Class<?> entityType, IndexCoordinates index) Deprecated.Description copied from interface:ReactiveDocumentOperations
Delete the documents matching the givenQuery
extracting index from entity metadata.- Parameters:
query
- must not be null.entityType
- must not be null.index
- the target index, must not be null- Returns:
- a
Mono
emitting the number of the removed documents.
-
update
public reactor.core.publisher.Mono<UpdateResponse> update(UpdateQuery updateQuery, IndexCoordinates index) Deprecated.Description copied from interface:ReactiveDocumentOperations
Partial update of the document.- Parameters:
updateQuery
- query defining the updateindex
- the index where to update the records- Returns:
- a
Mono
emitting the update response
-
updateByQuery
public reactor.core.publisher.Mono<ByQueryResponse> updateByQuery(UpdateQuery updateQuery, IndexCoordinates index) Deprecated.Description copied from interface:ReactiveDocumentOperations
Update document(s) by query.- Parameters:
updateQuery
- query defining the update, must not be nullindex
- the index where to update the records, must not be null- Returns:
- a
Mono
emitting the update response
-
reindex
Deprecated.Description copied from interface:ReactiveDocumentOperations
Copies documents from a source to a destination. The source can be any existing index, alias, or data stream. The destination must differ from the source. For example, you cannot reindex a data stream into itself. (@see https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-reindex.html)- Parameters:
postReindexRequest
- reindex request parameters- Returns:
- a
Mono
emitting the reindex response
-
submitReindex
Deprecated.Description copied from interface:ReactiveDocumentOperations
Submits a reindex task. (@see https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-reindex.html)- Parameters:
postReindexRequest
- reindex request parameters- Returns:
- a
Mono
emitting the task id.
-
doDeleteBy
protected reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse> doDeleteBy(Query query, Class<?> entityType, IndexCoordinates index) Deprecated. -
doDelete
protected reactor.core.publisher.Mono<String> doDelete(org.elasticsearch.action.delete.DeleteRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.- Parameters:
request
- the already preparedDeleteRequest
ready to be executed.- Returns:
- a
Mono
emitting the result of the operation.
-
doDeleteBy
protected reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse> doDeleteBy(org.elasticsearch.index.reindex.DeleteByQueryRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.- Parameters:
request
- the already preparedDeleteByQueryRequest
ready to be executed.- Returns:
- a
Mono
emitting the result of the operation.
-
prepareDeleteRequest
protected org.elasticsearch.action.delete.DeleteRequest prepareDeleteRequest(org.elasticsearch.action.delete.DeleteRequest request) Deprecated.Customization hook to modify a generatedDeleteRequest
prior to its execution. E.g. by setting therefresh policy
if applicable.- Parameters:
request
- the generatedDeleteRequest
.- Returns:
- never null.
-
prepareDeleteByRequest
protected org.elasticsearch.index.reindex.DeleteByQueryRequest prepareDeleteByRequest(org.elasticsearch.index.reindex.DeleteByQueryRequest request) Deprecated.Customization hook to modify a generatedDeleteByQueryRequest
prior to its execution. E.g. by setting therefresh policy
if applicable.- Parameters:
request
- the generatedDeleteByQueryRequest
.- Returns:
- never null.
-
prepareIndexRequest
protected org.elasticsearch.action.index.IndexRequest prepareIndexRequest(Object source, org.elasticsearch.action.index.IndexRequest request) Deprecated.Customization hook to modify a generatedIndexRequest
prior to its execution. E.g. by setting therefresh policy
if applicable.- Parameters:
source
- the source object theIndexRequest
was derived from.request
- the generatedIndexRequest
.- Returns:
- never null.
-
prepareWriteRequest
protected <R extends org.elasticsearch.action.support.WriteRequest<R>> R prepareWriteRequest(R request) Deprecated.Preprocess the write request before it is sent to the server, e.g. by setting therefresh policy
if applicable.- Type Parameters:
R
-- Parameters:
request
- must not be null.- Returns:
- the processed
WriteRequest
.
-
searchForPage
public <T> reactor.core.publisher.Mono<SearchPage<T>> searchForPage(Query query, Class<?> entityType, Class<T> resultType) Deprecated.Description copied from interface:ReactiveSearchOperations
Search the index for entities matching the givenquery
.- Specified by:
searchForPage
in interfaceReactiveSearchOperations
- Overrides:
searchForPage
in classAbstractReactiveElasticsearchTemplate
- Parameters:
query
- must not be null.entityType
- must not be null.resultType
- the projection result type.- Returns:
- a
Mono
emitting matching entities in aSearchHits
.
-
searchForPage
public <T> reactor.core.publisher.Mono<SearchPage<T>> searchForPage(Query query, Class<?> entityType, Class<T> resultType, IndexCoordinates index) Deprecated.Description copied from interface:ReactiveSearchOperations
Search the index for entities matching the givenquery
.- Specified by:
searchForPage
in interfaceReactiveSearchOperations
- Overrides:
searchForPage
in classAbstractReactiveElasticsearchTemplate
- Parameters:
query
- must not be null.entityType
- must not be null.resultType
- the projection result type.index
- the target index, must not be null- Returns:
- a
Mono
emitting matching entities in aSearchHits
.
-
doFind
protected reactor.core.publisher.Flux<SearchDocument> doFind(Query query, Class<?> clazz, IndexCoordinates index) Deprecated.- Specified by:
doFind
in classAbstractReactiveElasticsearchTemplate
-
doFindForResponse
protected <T> reactor.core.publisher.Mono<SearchDocumentResponse> doFindForResponse(Query query, Class<?> clazz, IndexCoordinates index) Deprecated.- Specified by:
doFindForResponse
in classAbstractReactiveElasticsearchTemplate
-
aggregate
public reactor.core.publisher.Flux<AggregationContainer<?>> aggregate(Query query, Class<?> entityType, IndexCoordinates index) Deprecated.Description copied from interface:ReactiveSearchOperations
Perform an aggregation specified by the givenquery
.- Parameters:
query
- must not be null.entityType
- must not be null.index
- the target index, must not be null- Returns:
- a
Flux
emitting matching aggregations one by one.
-
doAggregate
protected reactor.core.publisher.Flux<AggregationContainer<?>> doAggregate(org.elasticsearch.action.search.SearchRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.- Parameters:
request
- the already preparedSearchRequest
ready to be executed.- Returns:
- a
Flux
emitting the result of the operation.
-
doCount
protected reactor.core.publisher.Mono<Long> doCount(Query query, Class<?> entityType, IndexCoordinates index) Deprecated.- Specified by:
doCount
in classAbstractReactiveElasticsearchTemplate
-
doFind
protected reactor.core.publisher.Flux<SearchDocument> doFind(org.elasticsearch.action.search.SearchRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.- Parameters:
request
- the already preparedSearchRequest
ready to be executed.- Returns:
- a
Flux
emitting the result of the operation converted toSearchDocument
s.
-
doFindForResponse
protected <T> reactor.core.publisher.Mono<SearchDocumentResponse> doFindForResponse(org.elasticsearch.action.search.SearchRequest request, SearchDocumentResponse.EntityCreator<T> entityCreator) Deprecated.Customization hook on the actual execution resultMono
.- Parameters:
request
- the already preparedSearchRequest
ready to be executed.entityCreator
-- Returns:
- a
Mono
emitting the result of the operation converted to sSearchDocumentResponse
.
-
doCount
protected reactor.core.publisher.Mono<Long> doCount(org.elasticsearch.action.search.SearchRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.- Parameters:
request
- the already preparedSearchRequest
ready to be executed.- Returns:
- a
Mono
emitting the result of the operation.
-
doScroll
protected reactor.core.publisher.Flux<SearchDocument> doScroll(org.elasticsearch.action.search.SearchRequest request) Deprecated.Customization hook on the actual execution resultPublisher
.- Parameters:
request
- the already preparedSearchRequest
ready to be executed.- Returns:
- a
Flux
emitting the result of the operation converted toSearchDocument
s.
-
prepareSearchRequest
protected org.elasticsearch.action.search.SearchRequest prepareSearchRequest(org.elasticsearch.action.search.SearchRequest request, boolean useScroll) Deprecated.Customization hook to modify a generatedSearchRequest
prior to its execution. E.g. by setting theindices options
if applicable.- Parameters:
request
- the generatedSearchRequest
.useScroll
-- Returns:
- never null.
-
getClusterVersion
Deprecated.- Specified by:
getClusterVersion
in classAbstractReactiveElasticsearchTemplate
-
getVendor
Deprecated.- Specified by:
getVendor
in classAbstractReactiveElasticsearchTemplate
- Returns:
- the vendor name of the used cluster and client library
- Since:
- 4.3
-
getRuntimeLibraryVersion
Deprecated.- Specified by:
getRuntimeLibraryVersion
in classAbstractReactiveElasticsearchTemplate
- Returns:
- the version of the used client runtime library.
- Since:
- 4.3
-
matchAllQuery
Deprecated.Description copied from interface:ReactiveSearchOperations
Creates aQuery
to find all documents. Must be implemented by the concrete implementations to provide an appropriate query using the respective client.- Returns:
- a query to find all documents
-
idsQuery
Deprecated.Description copied from interface:ReactiveSearchOperations
Creates aQuery
to find get all documents with given ids. Must be implemented by the concrete implementations to provide an appropriate query using the respective client.- Parameters:
ids
- the list of ids must not be null- Returns:
- query returning the documents with the given ids
-
execute
public <T> org.reactivestreams.Publisher<T> execute(ReactiveElasticsearchOperations.ClientCallback<org.reactivestreams.Publisher<T>> callback) Deprecated.Description copied from interface:ReactiveElasticsearchOperations
Execute within aReactiveElasticsearchOperations.ClientCallback
managing resources and translating errors.- Type Parameters:
T
- the type the Publisher emits- Parameters:
callback
- must not be null.- Returns:
- the
Publisher
emitting results.
-
executeWithIndicesClient
public <T> org.reactivestreams.Publisher<T> executeWithIndicesClient(ReactiveElasticsearchOperations.IndicesClientCallback<org.reactivestreams.Publisher<T>> callback) Deprecated.Description copied from interface:ReactiveElasticsearchOperations
Execute within aReactiveElasticsearchOperations.IndicesClientCallback
managing resources and translating errors.- Type Parameters:
T
- the type the Publisher emits- Parameters:
callback
- must not be null.- Returns:
- the
Publisher
emitting results.
-
executeWithClusterClient
public <T> org.reactivestreams.Publisher<T> executeWithClusterClient(ReactiveElasticsearchOperations.ClusterClientCallback<org.reactivestreams.Publisher<T>> callback) Deprecated.Description copied from interface:ReactiveElasticsearchOperations
Execute within aReactiveElasticsearchOperations.ClusterClientCallback
managing resources and translating errors.- Type Parameters:
T
- the type the Publisher emits- Parameters:
callback
- must not be null.- Returns:
- the
Publisher
emitting results.
-
indexOps
Deprecated.Description copied from interface:ReactiveElasticsearchOperations
Creates aReactiveIndexOperations
that is bound to the given index- Parameters:
index
- IndexCoordinates specifying the index- Returns:
- ReactiveIndexOperations implementation
-
indexOps
Deprecated.Description copied from interface:ReactiveElasticsearchOperations
Creates aReactiveIndexOperations
that is bound to the given class- Parameters:
clazz
- the entity clazz specifiying the index information- Returns:
- ReactiveIndexOperations implementation
-
cluster
Deprecated.Description copied from interface:ReactiveElasticsearchOperations
return aReactiveClusterOperations
instance that uses the same client communication setup as this ElasticsearchOperations instance.- Returns:
- ClusterOperations implementation
-
getClient
Deprecated.Obtain theReactiveElasticsearchClient
to operate upon.- Returns:
- never null.
-
getIndicesClient
Deprecated.Obtain theReactiveElasticsearchClient.Indices
to operate upon.- Returns:
- never null.
-
getClusterClient
Deprecated.Obtain theReactiveElasticsearchClient.Cluster
to operate upon.- Returns:
- never null.
-