ReactiveElasticsearchOperations (Spring Data Elasticsearch 4.0.1.RELEASE API)

Skip navigation links

Spring Data Elasticsearch

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

All Superinterfaces:

ReactiveDocumentOperations, ReactiveSearchOperations

All Known Implementing Classes:

ReactiveElasticsearchTemplate
```
public interface ReactiveElasticsearchOperations
extends ReactiveDocumentOperations, ReactiveSearchOperations
```
Interface that specifies a basic set of Elasticsearch operations executed in a reactive way.
Implemented by ReactiveElasticsearchTemplate. Not often used but a useful option for extensibility and testability (as it can be easily mocked, stubbed, or be the target of a JDK proxy). Command execution using ReactiveElasticsearchOperations is deferred until a Subscriber subscribes to the Publisher.

Since:

3.2

Author:

Christoph Strobl, Peter-Josef Meisch

Nested Class Summary

Nested Classes
Modifier and Type	Interface and Description
`static interface`	`ReactiveElasticsearchOperations.ClientCallback<T extends org.reactivestreams.Publisher<?>>` Callback interface to be used with `execute(ClientCallback)` for operating directly on `ReactiveElasticsearchClient`.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`<T> org.reactivestreams.Publisher<T>`	`execute(ReactiveElasticsearchOperations.ClientCallback<org.reactivestreams.Publisher<T>> callback)` Execute within a `ReactiveElasticsearchOperations.ClientCallback` managing resources and translating errors.
`ElasticsearchConverter`	`getElasticsearchConverter()` Get the `ElasticsearchConverter` used.
`IndexCoordinates`	`getIndexCoordinatesFor(Class<?> clazz)`
`ElasticsearchPersistentEntity<?>`	`getPersistentEntityFor(Class<?> clazz)`

Methods inherited from interface org.springframework.data.elasticsearch.core.ReactiveDocumentOperations
bulkUpdate, bulkUpdate, delete, delete, delete, delete, delete, delete, delete, exists, exists, exists, findById, findById, get, get, multiGet, save, save, save, save, saveAll, saveAll

Methods inherited from interface org.springframework.data.elasticsearch.core.ReactiveSearchOperations
aggregate, aggregate, count, count, count, find, find, find, find, search, search, search, search

- Method Detail
  - execute
```
<T> org.reactivestreams.Publisher<T> execute(ReactiveElasticsearchOperations.ClientCallback<org.reactivestreams.Publisher<T>> callback)
```
    Execute within a ReactiveElasticsearchOperations.ClientCallback managing resources and translating errors.
    
    Type Parameters:
    
    T -
    
    Parameters:
    
    callback - must not be null.
    
    Returns:
    
    the Publisher emitting results.
  - 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

Skip navigation links

Spring Data Elasticsearch

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.