Package org.nuxeo.elasticsearch.client

Class ESTransportClient

java.lang.Object

org.nuxeo.elasticsearch.client.ESTransportClient

All Implemented Interfaces:

AutoCloseable, ESClient

public class ESTransportClient
extends Object
implements ESClient

Since:

9.3

Field Summary

Fields

Modifier and Type	Field	Description
protected org.opensearch.client.Client	client

Constructor Summary

Constructors

Constructor	Description
ESTransportClient(org.opensearch.client.Client client)

Method Summary

Modifier and Type	Method	Description
boolean	aliasExists(String aliasName)
org.opensearch.action.bulk.BulkResponse	bulk(org.opensearch.action.bulk.BulkRequest request)
org.opensearch.action.bulk.BulkProcessor.Builder	bulkProcessorBuilder(org.opensearch.action.bulk.BulkProcessor.Listener listener)	Creates an elasticsearch BulkProcessor builder.
org.opensearch.action.search.ClearScrollResponse	clearScroll(org.opensearch.action.search.ClearScrollRequest request)
void	close()
void	createIndex(String indexName, String jsonSettings)
void	createMapping(String indexName, String type, String jsonMapping)
org.opensearch.action.delete.DeleteResponse	delete(org.opensearch.action.delete.DeleteRequest request)
void	deleteIndex(String indexName, int timeoutSecond)
void	flush(String indexName)
org.opensearch.action.get.GetResponse	get(org.opensearch.action.get.GetRequest request)
String	getFirstIndexForAlias(String aliasName)	Returns the name of the index referenced by the alias.
org.opensearch.cluster.health.ClusterHealthStatus	getHealthStatus(String[] indexNames)
String	getMapping(String indexName)	Returns the mapping from elastic, exposed for testing purposes
String	getNodesInfo()
String	getNodesStats()
org.opensearch.action.index.IndexResponse	index(org.opensearch.action.index.IndexRequest request)	Performs the indexing request.
boolean	indexExists(String indexName)
boolean	mappingExists(String indexName, String type)
void	optimize(String indexName)
void	refresh(String indexName)
org.opensearch.action.search.SearchResponse	search(org.opensearch.action.search.SearchRequest request)
org.opensearch.action.search.SearchResponse	searchScroll(org.opensearch.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 Details

client

protected org.opensearch.client.Client client

Constructor Details

ESTransportClient

public ESTransportClient(org.opensearch.client.Client client)

Method Details

waitForYellowStatus

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

Specified by:

waitForYellowStatus in interface ESClient

getHealthStatus

public org.opensearch.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

getMapping

public String getMapping(String indexName)

Description copied from interface: ESClient

Returns the mapping from elastic, exposed for testing purposes

Specified by:

getMapping in interface ESClient

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

bulk

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

Specified by:

bulk in interface ESClient

delete

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

Specified by:

delete in interface ESClient

search

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

Specified by:

search in interface ESClient

searchScroll

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

Specified by:

searchScroll in interface ESClient

get

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

Specified by:

get in interface ESClient

index

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

Description copied from interface: ESClient

Performs the indexing request.

Specified by:

index in interface ESClient

clearScroll

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

Specified by:

clearScroll in interface ESClient

bulkProcessorBuilder

public org.opensearch.action.bulk.BulkProcessor.Builder bulkProcessorBuilder(org.opensearch.action.bulk.BulkProcessor.Listener listener)

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