public interface ESClient extends AutoCloseable
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 listener)
Creates an elasticsearch BulkProcessor builder.
|
org.elasticsearch.action.search.ClearScrollResponse |
clearScroll(org.elasticsearch.action.search.ClearScrollRequest request) |
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) |
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) |
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) |
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) |
close
boolean waitForYellowStatus(String[] indexNames, int timeoutSecond)
org.elasticsearch.cluster.health.ClusterHealthStatus getHealthStatus(String[] indexNames)
boolean indexExists(String indexName)
boolean mappingExists(String indexName, String type)
void deleteIndex(String indexName, int timeoutSecond)
void createIndex(String indexName, String jsonSettings)
void createMapping(String indexName, String type, String jsonMapping)
String getNodesInfo()
String getNodesStats()
boolean aliasExists(String aliasName)
String getFirstIndexForAlias(String aliasName)
void updateAlias(String aliasName, String indexName)
org.elasticsearch.action.bulk.BulkResponse bulk(org.elasticsearch.action.bulk.BulkRequest request)
org.elasticsearch.action.delete.DeleteResponse delete(org.elasticsearch.action.delete.DeleteRequest request)
org.elasticsearch.action.search.SearchResponse search(org.elasticsearch.action.search.SearchRequest request)
org.elasticsearch.action.search.SearchResponse searchScroll(org.elasticsearch.action.search.SearchScrollRequest request)
org.elasticsearch.action.get.GetResponse get(org.elasticsearch.action.get.GetRequest request)
org.elasticsearch.action.index.IndexResponse index(org.elasticsearch.action.index.IndexRequest request)
ConcurrentUpdateException
- if a more recent version of the document exits.org.elasticsearch.action.search.ClearScrollResponse clearScroll(org.elasticsearch.action.search.ClearScrollRequest request)
org.elasticsearch.action.bulk.BulkProcessor.Builder bulkProcessorBuilder(org.elasticsearch.action.bulk.BulkProcessor.Listener listener)
Copyright © 2019 Nuxeo. All rights reserved.