Interface ReactiveElasticsearchOperations

All Superinterfaces:

ReactiveDocumentOperations, ReactiveScriptOperations, ReactiveSearchOperations, ReactiveSqlOperations

All Known Implementing Classes:

AbstractReactiveElasticsearchTemplate, ReactiveElasticsearchTemplate

public interface ReactiveElasticsearchOperations
extends ReactiveDocumentOperations, ReactiveSearchOperations, ReactiveScriptOperations, ReactiveSqlOperations

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 ReactiveDocumentOperations

FLUX_SAVE_BULK_SIZE

Method Summary

Modifier and Type	Method	Description
ReactiveClusterOperations	cluster()	return a ReactiveClusterOperations instance that uses the same client communication setup as this ElasticsearchOperations instance.
ElasticsearchConverter	getElasticsearchConverter()	Get the ElasticsearchConverter used.
@Nullable String	getEntityRouting(Object entity)	gets the routing for an entity.
IndexCoordinates	getIndexCoordinatesFor(Class<?> clazz)
@Nullable ElasticsearchPersistentEntity<?>	getPersistentEntityFor(Class<?> clazz)
ReactiveIndexOperations	indexOps(Class<?> clazz)	Creates a ReactiveIndexOperations that is bound to the given class
ReactiveIndexOperations	indexOps(IndexCoordinates index)	Creates a ReactiveIndexOperations that is bound to the given index
ReactiveElasticsearchOperations	withRefreshPolicy(@Nullable RefreshPolicy refreshPolicy)	Returns a copy of this instance with the same configuration, but that uses a different RefreshPolicy.
ReactiveElasticsearchOperations	withRouting(RoutingResolver routingResolver)	Returns a copy of this instance with the same configuration, but that uses a different RoutingResolver to obtain routing information.

Methods inherited from interface ReactiveDocumentOperations

bulkUpdate, bulkUpdate, 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 ReactiveScriptOperations

deleteScript, getScript, putScript

Methods inherited from interface 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

Methods inherited from interface ReactiveSqlOperations

search

Method Details

getElasticsearchConverter

ElasticsearchConverter getElasticsearchConverter()

Get the ElasticsearchConverter used.

Returns:

never null

getPersistentEntityFor

@Nullable ElasticsearchPersistentEntity<?> getPersistentEntityFor(Class<?> clazz)

getIndexCoordinatesFor

IndexCoordinates getIndexCoordinatesFor(Class<?> clazz)

Parameters:

clazz -

Returns:

the IndexCoordinates defined on the entity.

Since:

4.0

indexOps

ReactiveIndexOperations indexOps(IndexCoordinates index)

Creates a ReactiveIndexOperations that is bound to the given index

Parameters:

index - IndexCoordinates specifying the index

Returns:

ReactiveIndexOperations implementation

Since:

4.1

indexOps

ReactiveIndexOperations indexOps(Class<?> clazz)

Creates a ReactiveIndexOperations 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 a ReactiveClusterOperations instance that uses the same client communication setup as this ElasticsearchOperations instance.

Returns:

ClusterOperations implementation

Since:

4.2

getEntityRouting

@Nullable String getEntityRouting(Object entity)

gets the routing for an entity.

Parameters:

entity - the entity

Returns:

the routing, may be null if not set.

Since:

5.2

withRouting

ReactiveElasticsearchOperations withRouting(RoutingResolver routingResolver)

Returns a copy of this instance with the same configuration, but that uses a different RoutingResolver to obtain routing information.

Parameters:

routingResolver - the RoutingResolver value, must not be null.

Returns:

DocumentOperations instance

withRefreshPolicy

ReactiveElasticsearchOperations withRefreshPolicy(@Nullable RefreshPolicy refreshPolicy)

Returns a copy of this instance with the same configuration, but that uses a different RefreshPolicy.

Parameters:

refreshPolicy - the RefreshPolicy value.

Returns:

ReactiveElasticsearchOperations instance.

Since:

5.2