com.github.vanroy.springdata.jest

Class JestElasticsearchTemplate

java.lang.Object

com.github.vanroy.springdata.jest.JestElasticsearchTemplate

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.data.elasticsearch.core.ElasticsearchOperations

public class JestElasticsearchTemplate
extends Object
implements org.springframework.data.elasticsearch.core.ElasticsearchOperations, org.springframework.context.ApplicationContextAware

Jest implementation of ElasticsearchOperations.

Author:

Julien Roy

Constructor Summary

Constructors

Constructor and Description
JestElasticsearchTemplate(io.searchbox.client.JestClient client)
JestElasticsearchTemplate(io.searchbox.client.JestClient client, org.springframework.data.elasticsearch.core.convert.ElasticsearchConverter elasticsearchConverter, JestResultsMapper resultsMapper)
JestElasticsearchTemplate(io.searchbox.client.JestClient client, JestResultsMapper resultMapper)

Method Summary

Modifier and Type	Method and Description
Boolean	addAlias(org.springframework.data.elasticsearch.core.query.AliasQuery query)
void	bulkIndex(List<org.springframework.data.elasticsearch.core.query.IndexQuery> queries)
void	bulkUpdate(List<org.springframework.data.elasticsearch.core.query.UpdateQuery> queries)
<T> void	clearScroll(String scrollId)
<T> long	count(org.springframework.data.elasticsearch.core.query.CriteriaQuery query)
<T> long	count(org.springframework.data.elasticsearch.core.query.CriteriaQuery criteriaQuery, Class<T> clazz)
<T> long	count(org.springframework.data.elasticsearch.core.query.SearchQuery query)
<T> long	count(org.springframework.data.elasticsearch.core.query.SearchQuery searchQuery, Class<T> clazz)
<T> boolean	createIndex(Class<T> clazz)
<T> boolean	createIndex(Class<T> clazz, Object settings)
boolean	createIndex(String indexName)
boolean	createIndex(String indexName, Object settings)
<T> String	delete(Class<T> clazz, String id)
<T> void	delete(org.springframework.data.elasticsearch.core.query.CriteriaQuery criteriaQuery, Class<T> clazz)
void	delete(org.springframework.data.elasticsearch.core.query.DeleteQuery deleteQuery)
<T> void	delete(org.springframework.data.elasticsearch.core.query.DeleteQuery deleteQuery, Class<T> clazz)
String	delete(String indexName, String type, String id)
<T> boolean	deleteIndex(Class<T> clazz)
boolean	deleteIndex(String indexName)
org.elasticsearch.client.Client	getClient()
org.springframework.data.elasticsearch.core.convert.ElasticsearchConverter	getElasticsearchConverter()
Set<String>	getIndicesFromAlias(String aliasName)
<T> Map	getMapping(Class<T> clazz)
Map	getMapping(String indexName, String type)
org.springframework.data.elasticsearch.core.mapping.ElasticsearchPersistentEntity	getPersistentEntityFor(Class clazz)
<T> Map	getSetting(Class<T> clazz)
Map	getSetting(String indexName)
String	index(org.springframework.data.elasticsearch.core.query.IndexQuery query)
<T> boolean	indexExists(Class<T> clazz)
boolean	indexExists(String indexName)
<T> org.springframework.data.domain.Page<T>	moreLikeThis(org.springframework.data.elasticsearch.core.query.MoreLikeThisQuery query, Class<T> clazz)
<T> LinkedList<T>	multiGet(org.springframework.data.elasticsearch.core.query.SearchQuery searchQuery, Class<T> clazz)
<T> LinkedList<T>	multiGet(org.springframework.data.elasticsearch.core.query.SearchQuery searchQuery, Class<T> clazz, JestMultiGetResultMapper getResultMapper)
<T> LinkedList<T>	multiGet(org.springframework.data.elasticsearch.core.query.SearchQuery searchQuery, Class<T> clazz, org.springframework.data.elasticsearch.core.MultiGetResultMapper getResultMapper)
<T> boolean	putMapping(Class<T> clazz)
<T> boolean	putMapping(Class<T> clazz, Object mapping)
boolean	putMapping(String indexName, String type, Object mapping)
<T> T	query(org.springframework.data.elasticsearch.core.query.SearchQuery query, JestResultsExtractor<T> resultsExtractor)
<T> T	query(org.springframework.data.elasticsearch.core.query.SearchQuery query, org.springframework.data.elasticsearch.core.ResultsExtractor<T> resultsExtractor)
List<org.elasticsearch.cluster.metadata.AliasMetaData>	queryForAlias(String indexName)
<T> List<String>	queryForIds(org.springframework.data.elasticsearch.core.query.SearchQuery query)
<T> List<T>	queryForList(org.springframework.data.elasticsearch.core.query.CriteriaQuery query, Class<T> clazz)
<T> List<T>	queryForList(org.springframework.data.elasticsearch.core.query.SearchQuery query, Class<T> clazz)
<T> List<T>	queryForList(org.springframework.data.elasticsearch.core.query.StringQuery query, Class<T> clazz)
<T> T	queryForObject(org.springframework.data.elasticsearch.core.query.CriteriaQuery query, Class<T> clazz)
<T> T	queryForObject(org.springframework.data.elasticsearch.core.query.GetQuery query, Class<T> clazz)
<T> T	queryForObject(org.springframework.data.elasticsearch.core.query.GetQuery query, Class<T> clazz, org.springframework.data.elasticsearch.core.GetResultMapper mapper)
<T> T	queryForObject(org.springframework.data.elasticsearch.core.query.GetQuery query, Class<T> clazz, JestGetResultMapper mapper)
<T> T	queryForObject(String indexName, org.springframework.data.elasticsearch.core.query.GetQuery query, Class<T> clazz)
<T> T	queryForObject(String indexName, org.springframework.data.elasticsearch.core.query.GetQuery query, Class<T> clazz, JestGetResultMapper mapper)
<T> T	queryForObject(org.springframework.data.elasticsearch.core.query.StringQuery query, Class<T> clazz)
<T> org.springframework.data.domain.Page<T>	queryForPage(org.springframework.data.elasticsearch.core.query.CriteriaQuery criteriaQuery, Class<T> clazz)
<T> AggregatedPage<T>	queryForPage(org.springframework.data.elasticsearch.core.query.SearchQuery query, Class<T> clazz)
<T> AggregatedPage<T>	queryForPage(org.springframework.data.elasticsearch.core.query.SearchQuery query, Class<T> clazz, JestSearchResultMapper mapper)
<T> AggregatedPage<T>	queryForPage(org.springframework.data.elasticsearch.core.query.SearchQuery query, Class<T> clazz, org.springframework.data.elasticsearch.core.SearchResultMapper mapper)
<T> org.springframework.data.domain.Page<T>	queryForPage(org.springframework.data.elasticsearch.core.query.StringQuery query, Class<T> clazz)
<T> org.springframework.data.domain.Page<T>	queryForPage(org.springframework.data.elasticsearch.core.query.StringQuery query, Class<T> clazz, JestSearchResultMapper mapper)
<T> org.springframework.data.domain.Page<T>	queryForPage(org.springframework.data.elasticsearch.core.query.StringQuery query, Class<T> clazz, org.springframework.data.elasticsearch.core.SearchResultMapper mapper)
static String	readFileFromClasspath(String url)
<T> void	refresh(Class<T> clazz)
void	refresh(String indexName)
Boolean	removeAlias(org.springframework.data.elasticsearch.core.query.AliasQuery query)
String	scan(org.springframework.data.elasticsearch.core.query.CriteriaQuery criteriaQuery, long scrollTimeInMillis, boolean noFields)
<T> String	scan(org.springframework.data.elasticsearch.core.query.CriteriaQuery query, long scrollTimeInMillis, boolean noFields, Class<T> clazz)
String	scan(org.springframework.data.elasticsearch.core.query.SearchQuery searchQuery, long scrollTimeInMillis, boolean noFields)
<T> String	scan(org.springframework.data.elasticsearch.core.query.SearchQuery query, long scrollTimeInMillis, boolean noFields, Class<T> clazz)
<T> org.springframework.data.domain.Page<T>	scroll(String scrollId, long scrollTimeInMillis, Class<T> clazz)
<T> org.springframework.data.domain.Page<T>	scroll(String scrollId, long scrollTimeInMillis, JestScrollResultMapper mapper)
<T> org.springframework.data.domain.Page<T>	scroll(String scrollId, long scrollTimeInMillis, org.springframework.data.elasticsearch.core.SearchResultMapper mapper)
void	setApplicationContext(org.springframework.context.ApplicationContext context)
<T> org.springframework.data.util.CloseableIterator<T>	stream(org.springframework.data.elasticsearch.core.query.CriteriaQuery query, Class<T> clazz)
<T> org.springframework.data.util.CloseableIterator<T>	stream(org.springframework.data.elasticsearch.core.query.SearchQuery query, Class<T> clazz)
<T> org.springframework.data.util.CloseableIterator<T>	stream(org.springframework.data.elasticsearch.core.query.SearchQuery query, Class<T> clazz, JestResultsMapper mapper)
<T> org.springframework.data.util.CloseableIterator<T>	stream(org.springframework.data.elasticsearch.core.query.SearchQuery query, Class<T> clazz, org.springframework.data.elasticsearch.core.SearchResultMapper mapper)
boolean	typeExists(String index, String type)
org.elasticsearch.action.update.UpdateResponse	update(org.springframework.data.elasticsearch.core.query.UpdateQuery updateQuery)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JestElasticsearchTemplate

public JestElasticsearchTemplate(io.searchbox.client.JestClient client)

JestElasticsearchTemplate

public JestElasticsearchTemplate(io.searchbox.client.JestClient client,
                                 JestResultsMapper resultMapper)

JestElasticsearchTemplate

public JestElasticsearchTemplate(io.searchbox.client.JestClient client,
                                 org.springframework.data.elasticsearch.core.convert.ElasticsearchConverter elasticsearchConverter,
                                 JestResultsMapper resultsMapper)

Method Detail

readFileFromClasspath

public static String readFileFromClasspath(String url)

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext context)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

getElasticsearchConverter

public org.springframework.data.elasticsearch.core.convert.ElasticsearchConverter getElasticsearchConverter()

Specified by:

getElasticsearchConverter in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

getClient

public org.elasticsearch.client.Client getClient()

Specified by:

getClient in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

createIndex

public <T> boolean createIndex(Class<T> clazz)

Specified by:

createIndex in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

createIndex

public boolean createIndex(String indexName)

Specified by:

createIndex in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

createIndex

public boolean createIndex(String indexName,
                           Object settings)

Specified by:

createIndex in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

createIndex

public <T> boolean createIndex(Class<T> clazz,
                               Object settings)

Specified by:

createIndex in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

putMapping

public <T> boolean putMapping(Class<T> clazz)

Specified by:

putMapping in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

putMapping

public boolean putMapping(String indexName,
                          String type,
                          Object mapping)

Specified by:

putMapping in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

putMapping

public <T> boolean putMapping(Class<T> clazz,
                              Object mapping)

Specified by:

putMapping in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

getMapping

public <T> Map getMapping(Class<T> clazz)

Specified by:

getMapping in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

getMapping

public Map getMapping(String indexName,
                      String type)

Specified by:

getMapping in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

getSetting

public Map getSetting(String indexName)

Specified by:

getSetting in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

getSetting

public <T> Map getSetting(Class<T> clazz)

Specified by:

getSetting in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForObject

public <T> T queryForObject(org.springframework.data.elasticsearch.core.query.GetQuery query,
                            Class<T> clazz)

Specified by:

queryForObject in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForObject

public <T> T queryForObject(org.springframework.data.elasticsearch.core.query.GetQuery query,
                            Class<T> clazz,
                            org.springframework.data.elasticsearch.core.GetResultMapper mapper)

Specified by:

queryForObject in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForObject

public <T> T queryForObject(org.springframework.data.elasticsearch.core.query.GetQuery query,
                            Class<T> clazz,
                            JestGetResultMapper mapper)

queryForObject

public <T> T queryForObject(String indexName,
                            org.springframework.data.elasticsearch.core.query.GetQuery query,
                            Class<T> clazz)

queryForObject

public <T> T queryForObject(String indexName,
                            org.springframework.data.elasticsearch.core.query.GetQuery query,
                            Class<T> clazz,
                            JestGetResultMapper mapper)

queryForObject

public <T> T queryForObject(org.springframework.data.elasticsearch.core.query.CriteriaQuery query,
                            Class<T> clazz)

Specified by:

queryForObject in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForObject

public <T> T queryForObject(org.springframework.data.elasticsearch.core.query.StringQuery query,
                            Class<T> clazz)

Specified by:

queryForObject in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForPage

public <T> AggregatedPage<T> queryForPage(org.springframework.data.elasticsearch.core.query.SearchQuery query,
                                          Class<T> clazz)

Specified by:

queryForPage in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForPage

public <T> AggregatedPage<T> queryForPage(org.springframework.data.elasticsearch.core.query.SearchQuery query,
                                          Class<T> clazz,
                                          org.springframework.data.elasticsearch.core.SearchResultMapper mapper)

Specified by:

queryForPage in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForPage

public <T> AggregatedPage<T> queryForPage(org.springframework.data.elasticsearch.core.query.SearchQuery query,
                                          Class<T> clazz,
                                          JestSearchResultMapper mapper)

query

public <T> T query(org.springframework.data.elasticsearch.core.query.SearchQuery query,
                   org.springframework.data.elasticsearch.core.ResultsExtractor<T> resultsExtractor)

Specified by:

query in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

query

public <T> T query(org.springframework.data.elasticsearch.core.query.SearchQuery query,
                   JestResultsExtractor<T> resultsExtractor)

queryForList

public <T> List<T> queryForList(org.springframework.data.elasticsearch.core.query.CriteriaQuery query,
                                Class<T> clazz)

Specified by:

queryForList in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForList

public <T> List<T> queryForList(org.springframework.data.elasticsearch.core.query.StringQuery query,
                                Class<T> clazz)

Specified by:

queryForList in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForList

public <T> List<T> queryForList(org.springframework.data.elasticsearch.core.query.SearchQuery query,
                                Class<T> clazz)

Specified by:

queryForList in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForIds

public <T> List<String> queryForIds(org.springframework.data.elasticsearch.core.query.SearchQuery query)

Specified by:

queryForIds in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForPage

public <T> org.springframework.data.domain.Page<T> queryForPage(org.springframework.data.elasticsearch.core.query.CriteriaQuery criteriaQuery,
                                                                Class<T> clazz)

Specified by:

queryForPage in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForPage

public <T> org.springframework.data.domain.Page<T> queryForPage(org.springframework.data.elasticsearch.core.query.StringQuery query,
                                                                Class<T> clazz)

Specified by:

queryForPage in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForPage

public <T> org.springframework.data.domain.Page<T> queryForPage(org.springframework.data.elasticsearch.core.query.StringQuery query,
                                                                Class<T> clazz,
                                                                org.springframework.data.elasticsearch.core.SearchResultMapper mapper)

Specified by:

queryForPage in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForPage

public <T> org.springframework.data.domain.Page<T> queryForPage(org.springframework.data.elasticsearch.core.query.StringQuery query,
                                                                Class<T> clazz,
                                                                JestSearchResultMapper mapper)

stream

public <T> org.springframework.data.util.CloseableIterator<T> stream(org.springframework.data.elasticsearch.core.query.CriteriaQuery query,
                                                                     Class<T> clazz)

Specified by:

stream in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

stream

public <T> org.springframework.data.util.CloseableIterator<T> stream(org.springframework.data.elasticsearch.core.query.SearchQuery query,
                                                                     Class<T> clazz)

Specified by:

stream in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

stream

public <T> org.springframework.data.util.CloseableIterator<T> stream(org.springframework.data.elasticsearch.core.query.SearchQuery query,
                                                                     Class<T> clazz,
                                                                     org.springframework.data.elasticsearch.core.SearchResultMapper mapper)

Specified by:

stream in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

stream

public <T> org.springframework.data.util.CloseableIterator<T> stream(org.springframework.data.elasticsearch.core.query.SearchQuery query,
                                                                     Class<T> clazz,
                                                                     JestResultsMapper mapper)

count

public <T> long count(org.springframework.data.elasticsearch.core.query.CriteriaQuery criteriaQuery,
                      Class<T> clazz)

Specified by:

count in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

count

public <T> long count(org.springframework.data.elasticsearch.core.query.SearchQuery searchQuery,
                      Class<T> clazz)

Specified by:

count in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

count

public <T> long count(org.springframework.data.elasticsearch.core.query.CriteriaQuery query)

Specified by:

count in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

count

public <T> long count(org.springframework.data.elasticsearch.core.query.SearchQuery query)

Specified by:

count in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

multiGet

public <T> LinkedList<T> multiGet(org.springframework.data.elasticsearch.core.query.SearchQuery searchQuery,
                                  Class<T> clazz,
                                  org.springframework.data.elasticsearch.core.MultiGetResultMapper getResultMapper)

Specified by:

multiGet in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

multiGet

public <T> LinkedList<T> multiGet(org.springframework.data.elasticsearch.core.query.SearchQuery searchQuery,
                                  Class<T> clazz,
                                  JestMultiGetResultMapper getResultMapper)

multiGet

public <T> LinkedList<T> multiGet(org.springframework.data.elasticsearch.core.query.SearchQuery searchQuery,
                                  Class<T> clazz)

Specified by:

multiGet in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

index

public String index(org.springframework.data.elasticsearch.core.query.IndexQuery query)

Specified by:

index in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

update

public org.elasticsearch.action.update.UpdateResponse update(org.springframework.data.elasticsearch.core.query.UpdateQuery updateQuery)

Specified by:

update in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

bulkIndex

public void bulkIndex(List<org.springframework.data.elasticsearch.core.query.IndexQuery> queries)

Specified by:

bulkIndex in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

bulkUpdate

public void bulkUpdate(List<org.springframework.data.elasticsearch.core.query.UpdateQuery> queries)

Specified by:

bulkUpdate in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

delete

public String delete(String indexName,
                     String type,
                     String id)

Specified by:

delete in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

delete

public <T> void delete(org.springframework.data.elasticsearch.core.query.CriteriaQuery criteriaQuery,
                       Class<T> clazz)

Specified by:

delete in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

delete

public <T> String delete(Class<T> clazz,
                         String id)

Specified by:

delete in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

delete

public <T> void delete(org.springframework.data.elasticsearch.core.query.DeleteQuery deleteQuery,
                       Class<T> clazz)

Specified by:

delete in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

delete

public void delete(org.springframework.data.elasticsearch.core.query.DeleteQuery deleteQuery)

Specified by:

delete in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

deleteIndex

public <T> boolean deleteIndex(Class<T> clazz)

Specified by:

deleteIndex in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

deleteIndex

public boolean deleteIndex(String indexName)

Specified by:

deleteIndex in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

indexExists

public <T> boolean indexExists(Class<T> clazz)

Specified by:

indexExists in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

indexExists

public boolean indexExists(String indexName)

Specified by:

indexExists in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

typeExists

public boolean typeExists(String index,
                          String type)

Specified by:

typeExists in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

refresh

public void refresh(String indexName)

Specified by:

refresh in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

refresh

public <T> void refresh(Class<T> clazz)

Specified by:

refresh in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

scan

public String scan(org.springframework.data.elasticsearch.core.query.CriteriaQuery criteriaQuery,
                   long scrollTimeInMillis,
                   boolean noFields)

Specified by:

scan in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

scan

public <T> String scan(org.springframework.data.elasticsearch.core.query.CriteriaQuery query,
                       long scrollTimeInMillis,
                       boolean noFields,
                       Class<T> clazz)

Specified by:

scan in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

scan

public String scan(org.springframework.data.elasticsearch.core.query.SearchQuery searchQuery,
                   long scrollTimeInMillis,
                   boolean noFields)

Specified by:

scan in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

scan

public <T> String scan(org.springframework.data.elasticsearch.core.query.SearchQuery query,
                       long scrollTimeInMillis,
                       boolean noFields,
                       Class<T> clazz)

Specified by:

scan in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

scroll

public <T> org.springframework.data.domain.Page<T> scroll(String scrollId,
                                                          long scrollTimeInMillis,
                                                          Class<T> clazz)

Specified by:

scroll in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

scroll

public <T> org.springframework.data.domain.Page<T> scroll(String scrollId,
                                                          long scrollTimeInMillis,
                                                          org.springframework.data.elasticsearch.core.SearchResultMapper mapper)

Specified by:

scroll in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

clearScroll

public <T> void clearScroll(String scrollId)

Specified by:

clearScroll in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

scroll

public <T> org.springframework.data.domain.Page<T> scroll(String scrollId,
                                                          long scrollTimeInMillis,
                                                          JestScrollResultMapper mapper)

moreLikeThis

public <T> org.springframework.data.domain.Page<T> moreLikeThis(org.springframework.data.elasticsearch.core.query.MoreLikeThisQuery query,
                                                                Class<T> clazz)

Specified by:

moreLikeThis in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

addAlias

public Boolean addAlias(org.springframework.data.elasticsearch.core.query.AliasQuery query)

Specified by:

addAlias in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

removeAlias

public Boolean removeAlias(org.springframework.data.elasticsearch.core.query.AliasQuery query)

Specified by:

removeAlias in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

queryForAlias

public List<org.elasticsearch.cluster.metadata.AliasMetaData> queryForAlias(String indexName)

Specified by:

queryForAlias in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations

getIndicesFromAlias

public Set<String> getIndicesFromAlias(String aliasName)

getPersistentEntityFor

public org.springframework.data.elasticsearch.core.mapping.ElasticsearchPersistentEntity getPersistentEntityFor(Class clazz)

Specified by:

getPersistentEntityFor in interface org.springframework.data.elasticsearch.core.ElasticsearchOperations