Package org.nuxeo.elasticsearch.core

Class ElasticSearchServiceImpl

java.lang.Object

org.nuxeo.elasticsearch.core.ElasticSearchServiceImpl

All Implemented Interfaces:

ElasticSearchService

public class ElasticSearchServiceImpl
extends Object
implements ElasticSearchService

Since:

6.0

Field Summary

Fields

Modifier and Type	Field	Description
protected final io.dropwizard.metrics5.Timer	fetchTimer
protected final io.dropwizard.metrics5.MetricRegistry	registry
protected final io.dropwizard.metrics5.Timer	scrollTimer
protected final io.dropwizard.metrics5.Timer	searchTimer

Constructor Summary

Constructors

Constructor	Description
ElasticSearchServiceImpl(ElasticSearchAdminImpl esa)

Method Summary

Modifier and Type	Method	Description
protected org.opensearch.action.search.SearchScrollRequest	buildEsScrollRequest(String scrollId, long keepAlive)
protected org.opensearch.action.search.SearchRequest	buildEsSearchRequest(NxQueryBuilder query, org.opensearch.action.search.SearchType searchType)
protected org.opensearch.action.search.SearchRequest	buildEsSearchScrollRequest(NxQueryBuilder query, org.opensearch.action.search.SearchType searchType, long keepAlive)
protected void	clearScroll(String scrollId)
void	clearScroll(EsScrollResult scrollResult)	Clear scroll on ElasticSearch cluster for the given EsScrollResult.
protected List<Aggregate<Bucket>>	getAggregates(NxQueryBuilder queryBuilder, org.opensearch.action.search.SearchResponse response)
protected DocumentModelListImpl	getDocumentModels(NxQueryBuilder queryBuilder, org.opensearch.action.search.SearchResponse response)
protected EsScrollResult	getScrollResults(NxQueryBuilder queryBuilder, org.opensearch.action.search.SearchResponse response, String scrollId, long keepAlive)
protected String	getSearchIndexesAsString(NxQueryBuilder query)
protected void	logScrollRequest(String scrollId, long keepAlive)
protected void	logSearchRequest(org.opensearch.action.search.SearchRequest request, NxQueryBuilder query, org.opensearch.action.search.SearchType searchType)
protected org.opensearch.action.search.SearchResponse	nextScroll(String scrollId, long keepAlive)
DocumentModelList	query(NxQueryBuilder queryBuilder)	Returns a document list using an NxQueryBuilder.
EsResult	queryAndAggregate(NxQueryBuilder queryBuilder)	Returns documents and aggregates.
EsScrollResult	scroll(EsScrollResult scrollResult)	Retrieves the next batch of results of a scrollable search request for the given EsScrollResult.
EsScrollResult	scroll(NxQueryBuilder queryBuilder, long keepAlive)	Performs the initial search of a scrollable search request using an NxQueryBuilder.
protected EsScrollResult	scroll(NxQueryBuilder queryBuilder, org.opensearch.action.search.SearchType searchType, long keepAlive)
protected org.opensearch.action.search.SearchResponse	search(NxQueryBuilder query)
protected org.opensearch.action.search.SearchResponse	searchScroll(NxQueryBuilder query, org.opensearch.action.search.SearchType searchType, long keepAlive)

Methods inherited from class java.lang.Object

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

Field Details

registry

protected final io.dropwizard.metrics5.MetricRegistry registry

searchTimer

protected final io.dropwizard.metrics5.Timer searchTimer

scrollTimer

protected final io.dropwizard.metrics5.Timer scrollTimer

fetchTimer

protected final io.dropwizard.metrics5.Timer fetchTimer

Constructor Details

ElasticSearchServiceImpl

public ElasticSearchServiceImpl(ElasticSearchAdminImpl esa)

Method Details

query

public DocumentModelList query(NxQueryBuilder queryBuilder)

Description copied from interface: ElasticSearchService

Returns a document list using an NxQueryBuilder.

Specified by:

query in interface ElasticSearchService

queryAndAggregate

public EsResult queryAndAggregate(NxQueryBuilder queryBuilder)

Description copied from interface: ElasticSearchService

Returns documents and aggregates.

Specified by:

queryAndAggregate in interface ElasticSearchService

scroll

public EsScrollResult scroll(NxQueryBuilder queryBuilder,
 long keepAlive)

Description copied from interface: ElasticSearchService

Performs the initial search of a scrollable search request using an NxQueryBuilder.

Specified by:

scroll in interface ElasticSearchService

keepAlive - the search context lifetime

Returns:

an EsScrollResult including the search results and a scroll id, to be passed to the subsequent calls to ElasticSearchService.scroll(EsScrollResult)

scroll

protected EsScrollResult scroll(NxQueryBuilder queryBuilder,
 org.opensearch.action.search.SearchType searchType,
 long keepAlive)

scroll

public EsScrollResult scroll(EsScrollResult scrollResult)

Description copied from interface: ElasticSearchService

Retrieves the next batch of results of a scrollable search request for the given EsScrollResult.

Specified by:

scroll in interface ElasticSearchService

Returns:

an EsScrollResult including the search results and a scroll id, to be passed to the subsequent calls to {code scroll}.

clearScroll

public void clearScroll(EsScrollResult scrollResult)

Description copied from interface: ElasticSearchService

Clear scroll on ElasticSearch cluster for the given EsScrollResult.

Specified by:

clearScroll in interface ElasticSearchService

clearScroll

protected void clearScroll(String scrollId)

getScrollResults

protected EsScrollResult getScrollResults(NxQueryBuilder queryBuilder,
 org.opensearch.action.search.SearchResponse response,
 String scrollId,
 long keepAlive)

getDocumentModels

protected DocumentModelListImpl getDocumentModels(NxQueryBuilder queryBuilder,
 org.opensearch.action.search.SearchResponse response)

getAggregates

protected List<Aggregate<Bucket>> getAggregates(NxQueryBuilder queryBuilder,
 org.opensearch.action.search.SearchResponse response)

search

protected org.opensearch.action.search.SearchResponse search(NxQueryBuilder query)

searchScroll

protected org.opensearch.action.search.SearchResponse searchScroll(NxQueryBuilder query,
 org.opensearch.action.search.SearchType searchType,
 long keepAlive)

nextScroll

protected org.opensearch.action.search.SearchResponse nextScroll(String scrollId,
 long keepAlive)

buildEsSearchRequest

protected org.opensearch.action.search.SearchRequest buildEsSearchRequest(NxQueryBuilder query,
 org.opensearch.action.search.SearchType searchType)

buildEsSearchScrollRequest

protected org.opensearch.action.search.SearchRequest buildEsSearchScrollRequest(NxQueryBuilder query,
 org.opensearch.action.search.SearchType searchType,
 long keepAlive)

buildEsScrollRequest

protected org.opensearch.action.search.SearchScrollRequest buildEsScrollRequest(String scrollId,
 long keepAlive)

logSearchRequest

protected void logSearchRequest(org.opensearch.action.search.SearchRequest request,
 NxQueryBuilder query,
 org.opensearch.action.search.SearchType searchType)

logScrollRequest

protected void logScrollRequest(String scrollId,
 long keepAlive)

getSearchIndexesAsString

protected String getSearchIndexesAsString(NxQueryBuilder query)