Interface ReactiveElasticsearchOperations
- All Superinterfaces:
ReactiveDocumentOperations
,ReactiveScriptOperations
,ReactiveSearchOperations
- All Known Implementing Classes:
AbstractReactiveElasticsearchTemplate
,ReactiveElasticsearchTemplate
public interface ReactiveElasticsearchOperations
extends ReactiveDocumentOperations, ReactiveSearchOperations, ReactiveScriptOperations
Interface that specifies a basic set of Elasticsearch operations executed in a reactive way.
- Since:
- 3.2
- Author:
- Christoph Strobl, Peter-Josef Meisch
-
Field Summary
Fields inherited from interface org.springframework.data.elasticsearch.core.ReactiveDocumentOperations
FLUX_SAVE_BULK_SIZE
-
Method Summary
Modifier and TypeMethodDescriptioncluster()
return aReactiveClusterOperations
instance that uses the same client communication setup as this ElasticsearchOperations instance.Get theElasticsearchConverter
used.getEntityRouting
(Object entity) gets the routing for an entity.getIndexCoordinatesFor
(Class<?> clazz) getPersistentEntityFor
(Class<?> clazz) Creates aReactiveIndexOperations
that is bound to the given classindexOps
(IndexCoordinates index) Creates aReactiveIndexOperations
that is bound to the given indexwithRefreshPolicy
(RefreshPolicy refreshPolicy) Returns a copy of this instance with the same configuration, but that uses a differentRefreshPolicy
.withRouting
(RoutingResolver routingResolver) Returns a copy of this instance with the same configuration, but that uses a differentRoutingResolver
to obtain routing information.Methods inherited from interface org.springframework.data.elasticsearch.core.ReactiveDocumentOperations
bulkUpdate, bulkUpdate, delete, delete, delete, delete, delete, delete, delete, delete, exists, exists, get, get, multiGet, multiGet, reindex, save, save, save, save, save, save, save, save, saveAll, saveAll, saveAll, saveAll, submitReindex, update, updateByQuery
Methods inherited from interface org.springframework.data.elasticsearch.core.script.ReactiveScriptOperations
deleteScript, getScript, putScript
Methods inherited from interface org.springframework.data.elasticsearch.core.ReactiveSearchOperations
aggregate, aggregate, closePointInTime, count, count, count, idsQuery, matchAllQuery, openPointInTime, openPointInTime, queryBuilderWithIds, search, search, search, search, searchForHits, searchForHits, searchForHits, searchForHits, searchForPage, searchForPage, searchForPage, searchForPage, suggest, suggest
-
Method Details
-
getElasticsearchConverter
ElasticsearchConverter getElasticsearchConverter()Get theElasticsearchConverter
used.- Returns:
- never null
-
getPersistentEntityFor
-
getIndexCoordinatesFor
- Parameters:
clazz
-- Returns:
- the IndexCoordinates defined on the entity.
- Since:
- 4.0
-
indexOps
Creates aReactiveIndexOperations
that is bound to the given index- Parameters:
index
- IndexCoordinates specifying the index- Returns:
- ReactiveIndexOperations implementation
- Since:
- 4.1
-
indexOps
Creates aReactiveIndexOperations
that is bound to the given class- Parameters:
clazz
- the entity clazz specifiying the index information- Returns:
- ReactiveIndexOperations implementation
- Since:
- 4.1
-
cluster
ReactiveClusterOperations cluster()return aReactiveClusterOperations
instance that uses the same client communication setup as this ElasticsearchOperations instance.- Returns:
- ClusterOperations implementation
- Since:
- 4.2
-
getEntityRouting
gets the routing for an entity.- Parameters:
entity
- the entity- Returns:
- the routing, may be null if not set.
- Since:
- 5.2
-
withRouting
Returns a copy of this instance with the same configuration, but that uses a differentRoutingResolver
to obtain routing information.- Parameters:
routingResolver
- theRoutingResolver
value, must not be null.- Returns:
- DocumentOperations instance
-
withRefreshPolicy
Returns a copy of this instance with the same configuration, but that uses a differentRefreshPolicy
.- Parameters:
refreshPolicy
- theRefreshPolicy
value.- Returns:
ReactiveElasticsearchOperations
instance.- Since:
- 5.2
-