org.nuxeo.elasticsearch.client

Class ESRestClient

java.lang.Object

org.nuxeo.elasticsearch.client.ESRestClient

All Implemented Interfaces:

AutoCloseable, ESClient

public class ESRestClient
extends Object
implements ESClient

Since:

9.3

Field Summary

Fields

Modifier and Type	Field and Description
protected org.elasticsearch.client.RestHighLevelClient	client
static String	CREATE_INDEX_TIMEOUT
protected org.elasticsearch.client.RestClient	lowLevelClient

Constructor Summary

Constructors

Constructor and Description
ESRestClient(org.elasticsearch.client.RestClient lowLevelRestClient, org.elasticsearch.client.RestHighLevelClient client)

Method Summary

Modifier and Type	Method and Description
boolean	aliasExists(String aliasName)
org.elasticsearch.action.bulk.BulkResponse	bulk(org.elasticsearch.action.bulk.BulkRequest request)
org.elasticsearch.action.bulk.BulkProcessor.Builder	bulkProcessorBuilder(org.elasticsearch.action.bulk.BulkProcessor.Listener bulkListener) Creates an elasticsearch BulkProcessor builder.
org.elasticsearch.action.search.ClearScrollResponse	clearScroll(org.elasticsearch.action.search.ClearScrollRequest request)
void	close()
protected void	createAlias(String aliasName, String indexName)
void	createIndex(String indexName, String jsonSettings)
void	createMapping(String indexName, String type, String jsonMapping)
org.elasticsearch.action.delete.DeleteResponse	delete(org.elasticsearch.action.delete.DeleteRequest request)
protected void	deleteAlias(String aliasName)
void	deleteIndex(String indexName, int timeoutSecond)
void	flush(String indexName)
org.elasticsearch.action.get.GetResponse	get(org.elasticsearch.action.get.GetRequest request)
String	getFirstIndexForAlias(String aliasName) Returns the name of the index referenced by the alias.
org.elasticsearch.cluster.health.ClusterHealthStatus	getHealthStatus(String[] indexNames)
protected String	getIndexesAsString(String[] indexNames)
String	getNodesInfo()
String	getNodesStats()
org.elasticsearch.action.index.IndexResponse	index(org.elasticsearch.action.index.IndexRequest request) Performs the indexing request.
boolean	indexExists(String indexName)
boolean	mappingExists(String indexName, String type)
void	optimize(String indexName)
protected org.elasticsearch.client.Response	performRequest(org.elasticsearch.client.Request request)
void	refresh(String indexName)
org.elasticsearch.action.search.SearchResponse	search(org.elasticsearch.action.search.SearchRequest request)
org.elasticsearch.action.search.SearchResponse	searchScroll(org.elasticsearch.action.search.SearchScrollRequest request)
void	updateAlias(String aliasName, String indexName)
boolean	waitForYellowStatus(String[] indexNames, int timeoutSecond)

Methods inherited from class java.lang.Object

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

Field Detail

CREATE_INDEX_TIMEOUT

public static final String CREATE_INDEX_TIMEOUT

See Also:

Constant Field Values

lowLevelClient

protected org.elasticsearch.client.RestClient lowLevelClient

client

protected org.elasticsearch.client.RestHighLevelClient client

Constructor Detail

ESRestClient

public ESRestClient(org.elasticsearch.client.RestClient lowLevelRestClient,
                    org.elasticsearch.client.RestHighLevelClient client)

Method Detail

waitForYellowStatus

public boolean waitForYellowStatus(String[] indexNames,
                                   int timeoutSecond)

Specified by:

waitForYellowStatus in interface ESClient

getIndexesAsString

protected String getIndexesAsString(String[] indexNames)

getHealthStatus

public org.elasticsearch.cluster.health.ClusterHealthStatus getHealthStatus(String[] indexNames)

Specified by:

getHealthStatus in interface ESClient

refresh

public void refresh(String indexName)

Specified by:

refresh in interface ESClient

flush

public void flush(String indexName)

Specified by:

flush in interface ESClient

optimize

public void optimize(String indexName)

Specified by:

optimize in interface ESClient

indexExists

public boolean indexExists(String indexName)

Specified by:

indexExists in interface ESClient

mappingExists

public boolean mappingExists(String indexName,
                             String type)

Specified by:

mappingExists in interface ESClient

deleteIndex

public void deleteIndex(String indexName,
                        int timeoutSecond)

Specified by:

deleteIndex in interface ESClient

createIndex

public void createIndex(String indexName,
                        String jsonSettings)

Specified by:

createIndex in interface ESClient

createMapping

public void createMapping(String indexName,
                          String type,
                          String jsonMapping)

Specified by:

createMapping in interface ESClient

performRequest

protected org.elasticsearch.client.Response performRequest(org.elasticsearch.client.Request request)

getNodesInfo

public String getNodesInfo()

Specified by:

getNodesInfo in interface ESClient

getNodesStats

public String getNodesStats()

Specified by:

getNodesStats in interface ESClient

aliasExists

public boolean aliasExists(String aliasName)

Specified by:

aliasExists in interface ESClient

getFirstIndexForAlias

public String getFirstIndexForAlias(String aliasName)

Description copied from interface: ESClient

Returns the name of the index referenced by the alias. Returns null if the alias does not exists.

Specified by:

getFirstIndexForAlias in interface ESClient

updateAlias

public void updateAlias(String aliasName,
                        String indexName)

Specified by:

updateAlias in interface ESClient

deleteAlias

protected void deleteAlias(String aliasName)

createAlias

protected void createAlias(String aliasName,
                           String indexName)

bulk

public org.elasticsearch.action.bulk.BulkResponse bulk(org.elasticsearch.action.bulk.BulkRequest request)

Specified by:

bulk in interface ESClient

delete

public org.elasticsearch.action.delete.DeleteResponse delete(org.elasticsearch.action.delete.DeleteRequest request)

Specified by:

delete in interface ESClient

search

public org.elasticsearch.action.search.SearchResponse search(org.elasticsearch.action.search.SearchRequest request)

Specified by:

search in interface ESClient

searchScroll

public org.elasticsearch.action.search.SearchResponse searchScroll(org.elasticsearch.action.search.SearchScrollRequest request)

Specified by:

searchScroll in interface ESClient

get

public org.elasticsearch.action.get.GetResponse get(org.elasticsearch.action.get.GetRequest request)

Specified by:

get in interface ESClient

index

public org.elasticsearch.action.index.IndexResponse index(org.elasticsearch.action.index.IndexRequest request)

Description copied from interface: ESClient

Performs the indexing request.

Specified by:

index in interface ESClient

clearScroll

public org.elasticsearch.action.search.ClearScrollResponse clearScroll(org.elasticsearch.action.search.ClearScrollRequest request)

Specified by:

clearScroll in interface ESClient

bulkProcessorBuilder

public org.elasticsearch.action.bulk.BulkProcessor.Builder bulkProcessorBuilder(org.elasticsearch.action.bulk.BulkProcessor.Listener bulkListener)

Description copied from interface: ESClient

Creates an elasticsearch BulkProcessor builder.

Specified by:

bulkProcessorBuilder in interface ESClient

close

public void close()

Specified by:

close in interface AutoCloseable