public class ElasticsearchRestTemplate extends AbstractElasticsearchTemplate
elasticsearchConverter, indexOperations, requestFactory
Constructor and Description |
---|
ElasticsearchRestTemplate(org.elasticsearch.client.RestHighLevelClient client) |
ElasticsearchRestTemplate(org.elasticsearch.client.RestHighLevelClient client,
ElasticsearchConverter elasticsearchConverter) |
Modifier and Type | Method and Description |
---|---|
List<String> |
bulkIndex(List<IndexQuery> queries,
BulkOptions bulkOptions,
IndexCoordinates index)
Bulk index all objects.
|
void |
bulkUpdate(List<UpdateQuery> queries,
BulkOptions bulkOptions,
IndexCoordinates index)
Bulk update all objects.
|
long |
count(Query query,
Class<?> clazz,
IndexCoordinates index)
return number of elements found by given query
|
void |
delete(DeleteQuery deleteQuery,
IndexCoordinates index)
Delete all records matching the query.
|
String |
delete(String id,
IndexCoordinates index)
Delete the one object with provided id.
|
<T> T |
get(GetQuery query,
Class<T> clazz,
IndexCoordinates index)
Retrieves an object from an index.
|
protected org.elasticsearch.action.search.MultiSearchResponse.Item[] |
getMultiSearchResult(org.elasticsearch.action.search.MultiSearchRequest request) |
String |
index(IndexQuery query,
IndexCoordinates index)
Index an object.
|
<T> List<T> |
multiGet(Query query,
Class<T> clazz,
IndexCoordinates index)
Execute a multiGet against elasticsearch for the given ids.
|
<T> SearchHits<T> |
search(Query query,
Class<T> clazz,
IndexCoordinates index)
Execute the criteria query against elasticsearch and return result as
SearchHits |
void |
searchScrollClear(String scrollId)
Clears the search contexts associated with specified scroll ids.
|
<T> ScrolledPage<SearchHit<T>> |
searchScrollContinue(String scrollId,
long scrollTimeInMillis,
Class<T> clazz)
Returns next scrolled page
|
<T> ScrolledPage<SearchHit<T>> |
searchScrollStart(long scrollTimeInMillis,
Query query,
Class<T> clazz,
IndexCoordinates index)
Returns scrolled page for given query
|
org.elasticsearch.action.search.SearchResponse |
suggest(org.elasticsearch.search.suggest.SuggestBuilder suggestion,
IndexCoordinates index)
Does a suggest query
|
org.elasticsearch.action.update.UpdateResponse |
update(UpdateQuery query,
IndexCoordinates index)
Partial update of the document.
|
checkForBulkOperationFailure, createElasticsearchConverter, delete, getElasticsearchConverter, getIndexCoordinatesFor, getIndexOperations, getRequestFactory, initialize, multiSearch, multiSearch, save, save, save, save, save, search, searchForStream, setApplicationContext, setPersistentEntityId, stream, toArray
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAlias, createIndex, createIndex, createIndex, createIndex, deleteIndex, deleteIndex, getMapping, getMapping, getSetting, getSetting, indexExists, indexExists, putMapping, putMapping, putMapping, putMapping, queryForAlias, refresh, refresh, removeAlias, stringIdRepresentation
bulkIndex, bulkUpdate
clearScroll, continueScroll, count, moreLikeThis, queryForIds, queryForList, queryForList, queryForList, queryForObject, queryForPage, queryForPage, queryForPage, searchOne, startScroll
public ElasticsearchRestTemplate(org.elasticsearch.client.RestHighLevelClient client)
public ElasticsearchRestTemplate(org.elasticsearch.client.RestHighLevelClient client, ElasticsearchConverter elasticsearchConverter)
public String index(IndexQuery query, IndexCoordinates index)
DocumentOperations
query
- the query defining the objectindex
- the index from which the object is read.@Nullable public <T> T get(GetQuery query, Class<T> clazz, IndexCoordinates index)
DocumentOperations
query
- the query defining the id of the object to getclazz
- the type of the object to be returnedindex
- the index from which the object is read.public <T> List<T> multiGet(Query query, Class<T> clazz, IndexCoordinates index)
DocumentOperations
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.public List<String> bulkIndex(List<IndexQuery> queries, BulkOptions bulkOptions, IndexCoordinates index)
DocumentOperations
queries
- the queries to execute in bulkbulkOptions
- options to be added to the bulk requestpublic void bulkUpdate(List<UpdateQuery> queries, BulkOptions bulkOptions, IndexCoordinates index)
DocumentOperations
queries
- the queries to execute in bulkbulkOptions
- options to be added to the bulk requestpublic String delete(String id, IndexCoordinates index)
DocumentOperations
id
- the document ot deleteindex
- the index from which to deletepublic void delete(DeleteQuery deleteQuery, IndexCoordinates index)
DocumentOperations
deleteQuery
- query defining the objectsindex
- the index where to delete the recordspublic org.elasticsearch.action.update.UpdateResponse update(UpdateQuery query, IndexCoordinates index)
DocumentOperations
query
- query defining the updateindex
- the index where to update the recordspublic long count(Query query, @Nullable Class<?> clazz, IndexCoordinates index)
SearchOperations
query
- the query to executeclazz
- the entity clazz used for property mappingindex
- the index to run the query againstpublic <T> SearchHits<T> search(Query query, Class<T> clazz, IndexCoordinates index)
SearchOperations
SearchHits
T
- element return typequery
- the query to executeclazz
- the entity clazz used for property mappingindex
- the index to run the query againstpublic <T> ScrolledPage<SearchHit<T>> searchScrollStart(long scrollTimeInMillis, Query query, Class<T> clazz, IndexCoordinates index)
SearchOperations
scrollTimeInMillis
- duration of the scroll timequery
- The search query.clazz
- The class of entity to retrieve.index
- the index to run the query againstpublic <T> ScrolledPage<SearchHit<T>> searchScrollContinue(@Nullable String scrollId, long scrollTimeInMillis, Class<T> clazz)
SearchOperations
scrollId
- the scroll idscrollTimeInMillis
- duration of the scroll timeclazz
- The class of entity to retrieve.public void searchScrollClear(String scrollId)
SearchOperations
scrollId
- the scroll idpublic org.elasticsearch.action.search.SearchResponse suggest(org.elasticsearch.search.suggest.SuggestBuilder suggestion, IndexCoordinates index)
SearchOperations
suggest
in interface SearchOperations
suggest
in class AbstractElasticsearchTemplate
suggestion
- the queryindex
- the index to run the query againstprotected org.elasticsearch.action.search.MultiSearchResponse.Item[] getMultiSearchResult(org.elasticsearch.action.search.MultiSearchRequest request)
getMultiSearchResult
in class AbstractElasticsearchTemplate
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.