Class RestHighLevelClient
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public class RestHighLevelClient
extends java.lang.Object
implements java.io.Closeable
RestClient
and allows to build requests and read responses. The
RestClient
instance is internally built based on the provided RestClientBuilder
and it gets closed automatically when
closing the RestHighLevelClient
instance that wraps it.
In case an already existing instance of a low-level REST client needs to be provided, this class can be subclassed and the
RestHighLevelClient(RestClient, CheckedConsumer, List)
constructor can be used.
This class can also be sub-classed to expose additional client methods that make use of endpoints added to Elasticsearch through plugins, or to add support for custom response sections, again added to Elasticsearch through plugins.
The majority of the methods in this class come in two flavors, a blocking and an asynchronous version (e.g.
search(SearchRequest, RequestOptions)
and searchAsync(SearchRequest, RequestOptions, ActionListener)
, where the later
takes an implementation of an ActionListener
as an argument that needs to implement methods that handle successful responses and
failure scenarios. Most of the blocking calls can throw an IOException
or an unchecked ElasticsearchException
in the
following cases:
- an
IOException
is usually thrown in case of failing to parse the REST response in the high-level REST client, the request times out or similar cases where there is no response coming back from the Elasticsearch server - an
ElasticsearchException
is usually thrown in case where the server returns a 4xx or 5xx error code. The high-level client then tries to parse the response body error details into a generic ElasticsearchException and suppresses the originalResponseException
-
Constructor Summary
Constructors Modifier Constructor Description RestHighLevelClient(org.elasticsearch.client.RestClientBuilder restClientBuilder)
Creates aRestHighLevelClient
given the low levelRestClientBuilder
that allows to build theRestClient
to be used to perform requests.protected
RestHighLevelClient(org.elasticsearch.client.RestClientBuilder restClientBuilder, java.util.List<org.elasticsearch.common.xcontent.NamedXContentRegistry.Entry> namedXContentEntries)
Creates aRestHighLevelClient
given the low levelRestClientBuilder
that allows to build theRestClient
to be used to perform requests and parsers for custom response sections added to Elasticsearch through plugins.protected
RestHighLevelClient(org.elasticsearch.client.RestClient restClient, org.elasticsearch.common.CheckedConsumer<org.elasticsearch.client.RestClient,java.io.IOException> doClose, java.util.List<org.elasticsearch.common.xcontent.NamedXContentRegistry.Entry> namedXContentEntries)
Creates aRestHighLevelClient
given the low levelRestClient
that it should use to perform requests and a list of entries that allow to parse custom response sections added to Elasticsearch through plugins. -
Method Summary
Modifier and Type Method Description AsyncSearchClient
asyncSearch()
A wrapper for theRestHighLevelClient
that provides methods for accessing the Elastic Index Async Search APIs.org.elasticsearch.action.bulk.BulkResponse
bulk(org.elasticsearch.action.bulk.BulkRequest bulkRequest, org.elasticsearch.client.RequestOptions options)
Executes a bulk request using the Bulk API.org.elasticsearch.client.Cancellable
bulkAsync(org.elasticsearch.action.bulk.BulkRequest bulkRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.bulk.BulkResponse> listener)
Asynchronously executes a bulk request using the Bulk API.CcrClient
ccr()
Provides methods for accessing the Elastic Licensed CCR APIs that are shipped with the Elastic Stack distribution of Elasticsearch.org.elasticsearch.action.search.ClearScrollResponse
clearScroll(org.elasticsearch.action.search.ClearScrollRequest clearScrollRequest, org.elasticsearch.client.RequestOptions options)
Clears one or more scroll ids using the Clear Scroll API.org.elasticsearch.client.Cancellable
clearScrollAsync(org.elasticsearch.action.search.ClearScrollRequest clearScrollRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.ClearScrollResponse> listener)
Asynchronously clears one or more scroll ids using the Clear Scroll API.void
close()
ClusterClient
cluster()
Provides aClusterClient
which can be used to access the Cluster API.protected static boolean
convertExistsResponse(org.elasticsearch.client.Response response)
CountResponse
count(CountRequest countRequest, org.elasticsearch.client.RequestOptions options)
Executes a count request using the Count API.org.elasticsearch.client.Cancellable
countAsync(CountRequest countRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<CountResponse> listener)
Asynchronously executes a count request using the Count API.org.elasticsearch.action.delete.DeleteResponse
delete(org.elasticsearch.action.delete.DeleteRequest deleteRequest, org.elasticsearch.client.RequestOptions options)
Deletes a document by id using the Delete API.org.elasticsearch.client.Cancellable
deleteAsync(org.elasticsearch.action.delete.DeleteRequest deleteRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.delete.DeleteResponse> listener)
Asynchronously deletes a document by id using the Delete API.org.elasticsearch.index.reindex.BulkByScrollResponse
deleteByQuery(org.elasticsearch.index.reindex.DeleteByQueryRequest deleteByQueryRequest, org.elasticsearch.client.RequestOptions options)
Executes a delete by query request.org.elasticsearch.client.Cancellable
deleteByQueryAsync(org.elasticsearch.index.reindex.DeleteByQueryRequest deleteByQueryRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.index.reindex.BulkByScrollResponse> listener)
Asynchronously executes a delete by query request.org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse
deleteByQueryRethrottle(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options)
Executes a delete by query rethrottle request.org.elasticsearch.client.Cancellable
deleteByQueryRethrottleAsync(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse> listener)
Asynchronously execute an delete by query rethrottle request.org.elasticsearch.action.support.master.AcknowledgedResponse
deleteScript(org.elasticsearch.action.admin.cluster.storedscripts.DeleteStoredScriptRequest request, org.elasticsearch.client.RequestOptions options)
Delete stored script by id.org.elasticsearch.client.Cancellable
deleteScriptAsync(org.elasticsearch.action.admin.cluster.storedscripts.DeleteStoredScriptRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.support.master.AcknowledgedResponse> listener)
Asynchronously delete stored script by id.EnrichClient
enrich()
EqlClient
eql()
Provides methods for accessing the Elastic EQL APIs that are shipped with the Elastic Stack distribution of Elasticsearch.boolean
exists(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options)
Checks for the existence of a document.org.elasticsearch.client.Cancellable
existsAsync(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<java.lang.Boolean> listener)
Asynchronously checks for the existence of a document.boolean
existsSource(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options)
Deprecated.useexistsSource(GetSourceRequest, RequestOptions)
insteadboolean
existsSource(GetSourceRequest getSourceRequest, org.elasticsearch.client.RequestOptions options)
Checks for the existence of a document with a "_source" field.org.elasticsearch.client.Cancellable
existsSourceAsync(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<java.lang.Boolean> listener)
Deprecated.org.elasticsearch.client.Cancellable
existsSourceAsync(GetSourceRequest getSourceRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<java.lang.Boolean> listener)
Asynchronously checks for the existence of a document with a "_source" field.org.elasticsearch.action.explain.ExplainResponse
explain(org.elasticsearch.action.explain.ExplainRequest explainRequest, org.elasticsearch.client.RequestOptions options)
Executes a request using the Explain API.org.elasticsearch.client.Cancellable
explainAsync(org.elasticsearch.action.explain.ExplainRequest explainRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.explain.ExplainResponse> listener)
Asynchronously executes a request using the Explain API.org.elasticsearch.action.fieldcaps.FieldCapabilitiesResponse
fieldCaps(org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequest fieldCapabilitiesRequest, org.elasticsearch.client.RequestOptions options)
Executes a request using the Field Capabilities API.org.elasticsearch.client.Cancellable
fieldCapsAsync(org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequest fieldCapabilitiesRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.fieldcaps.FieldCapabilitiesResponse> listener)
Asynchronously executes a request using the Field Capabilities API.org.elasticsearch.action.get.GetResponse
get(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options)
Retrieves a document by id using the Get API.org.elasticsearch.client.Cancellable
getAsync(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.get.GetResponse> listener)
Asynchronously retrieves a document by id using the Get API.org.elasticsearch.client.RestClient
getLowLevelClient()
Returns the low-level client that the current high-level client instance is using to perform requestsorg.elasticsearch.action.admin.cluster.storedscripts.GetStoredScriptResponse
getScript(org.elasticsearch.action.admin.cluster.storedscripts.GetStoredScriptRequest request, org.elasticsearch.client.RequestOptions options)
Get stored script by id.org.elasticsearch.client.Cancellable
getScriptAsync(org.elasticsearch.action.admin.cluster.storedscripts.GetStoredScriptRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.admin.cluster.storedscripts.GetStoredScriptResponse> listener)
Asynchronously get stored script by id.GetSourceResponse
getSource(GetSourceRequest getSourceRequest, org.elasticsearch.client.RequestOptions options)
Retrieves the source field only of a document using GetSource API.org.elasticsearch.client.Cancellable
getSourceAsync(GetSourceRequest getSourceRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<GetSourceResponse> listener)
Asynchronously retrieves the source field only of a document using GetSource API.GraphClient
graph()
Provides methods for accessing the Elastic Licensed Graph explore API that is shipped with the default distribution of Elasticsearch.org.elasticsearch.action.index.IndexResponse
index(org.elasticsearch.action.index.IndexRequest indexRequest, org.elasticsearch.client.RequestOptions options)
Index a document using the Index API.org.elasticsearch.client.Cancellable
indexAsync(org.elasticsearch.action.index.IndexRequest indexRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.index.IndexResponse> listener)
Asynchronously index a document using the Index API.IndexLifecycleClient
indexLifecycle()
A wrapper for theRestHighLevelClient
that provides methods for accessing the Elastic Index Lifecycle APIs.IndicesClient
indices()
Provides anIndicesClient
which can be used to access the Indices API.MainResponse
info(org.elasticsearch.client.RequestOptions options)
Get the cluster info otherwise provided when sending an HTTP request to '/'IngestClient
ingest()
Provides aIngestClient
which can be used to access the Ingest API.LicenseClient
license()
Provides methods for accessing the Elastic Licensed Licensing APIs that are shipped with the default distribution of Elasticsearch.MachineLearningClient
machineLearning()
Provides methods for accessing the Elastic Licensed Machine Learning APIs that are shipped with the Elastic Stack distribution of Elasticsearch.org.elasticsearch.action.get.MultiGetResponse
mget(org.elasticsearch.action.get.MultiGetRequest multiGetRequest, org.elasticsearch.client.RequestOptions options)
Retrieves multiple documents by id using the Multi Get API.org.elasticsearch.client.Cancellable
mgetAsync(org.elasticsearch.action.get.MultiGetRequest multiGetRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.get.MultiGetResponse> listener)
Asynchronously retrieves multiple documents by id using the Multi Get API.MigrationClient
migration()
Provides methods for accessing the Elastic Licensed Migration APIs that are shipped with the default distribution of Elasticsearch.org.elasticsearch.action.search.MultiSearchResponse
msearch(org.elasticsearch.action.search.MultiSearchRequest multiSearchRequest, org.elasticsearch.client.RequestOptions options)
Executes a multi search using the msearch API.org.elasticsearch.client.Cancellable
msearchAsync(org.elasticsearch.action.search.MultiSearchRequest searchRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.MultiSearchResponse> listener)
Asynchronously executes a multi search using the msearch API.org.elasticsearch.script.mustache.MultiSearchTemplateResponse
msearchTemplate(org.elasticsearch.script.mustache.MultiSearchTemplateRequest multiSearchTemplateRequest, org.elasticsearch.client.RequestOptions options)
Executes a request using the Multi Search Template API.org.elasticsearch.client.Cancellable
msearchTemplateAsync(org.elasticsearch.script.mustache.MultiSearchTemplateRequest multiSearchTemplateRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.script.mustache.MultiSearchTemplateResponse> listener)
Asynchronously executes a request using the Multi Search Template API See Multi Search Template API on elastic.co.MultiTermVectorsResponse
mtermvectors(MultiTermVectorsRequest request, org.elasticsearch.client.RequestOptions options)
Calls the Multi Term Vectors API See Multi Term Vectors API on elastic.coorg.elasticsearch.client.Cancellable
mtermvectorsAsync(MultiTermVectorsRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<MultiTermVectorsResponse> listener)
Asynchronously calls the Multi Term Vectors API See Multi Term Vectors API on elastic.coorg.elasticsearch.action.get.MultiGetResponse
multiGet(org.elasticsearch.action.get.MultiGetRequest multiGetRequest, org.elasticsearch.client.RequestOptions options)
Deprecated.usemget(MultiGetRequest, RequestOptions)
insteadorg.elasticsearch.client.Cancellable
multiGetAsync(org.elasticsearch.action.get.MultiGetRequest multiGetRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.get.MultiGetResponse> listener)
Deprecated.org.elasticsearch.action.search.MultiSearchResponse
multiSearch(org.elasticsearch.action.search.MultiSearchRequest multiSearchRequest, org.elasticsearch.client.RequestOptions options)
Deprecated.usemsearch(MultiSearchRequest, RequestOptions)
insteadorg.elasticsearch.client.Cancellable
multiSearchAsync(org.elasticsearch.action.search.MultiSearchRequest searchRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.MultiSearchResponse> listener)
Deprecated.protected <Resp> Resp
parseEntity(org.apache.http.HttpEntity entity, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser)
protected org.elasticsearch.ElasticsearchStatusException
parseResponseException(org.elasticsearch.client.ResponseException responseException)
Converts aResponseException
obtained from the low level REST client into anElasticsearchException
.protected <Req extends org.elasticsearch.action.ActionRequest, Resp>
RespperformRequest(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.client.Response,Resp,java.io.IOException> responseConverter, java.util.Set<java.lang.Integer> ignores)
Deprecated.If creating a new HLRC ReST API call, consider creating new actions instead of reusing server actions.protected <Req extends org.elasticsearch.action.ActionRequest, Resp>
RespperformRequestAndParseEntity(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser, java.util.Set<java.lang.Integer> ignores)
Deprecated.If creating a new HLRC ReST API call, consider creating new actions instead of reusing server actions.protected <Req extends Validatable, Resp>
java.util.Optional<Resp>performRequestAndParseOptionalEntity(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser)
Defines a helper method for requests that can 404 and in which case will return an empty Optional otherwise tries to parse the response bodyprotected <Req extends org.elasticsearch.action.ActionRequest, Resp>
org.elasticsearch.client.CancellableperformRequestAsync(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.client.Response,Resp,java.io.IOException> responseConverter, org.elasticsearch.action.ActionListener<Resp> listener, java.util.Set<java.lang.Integer> ignores)
Deprecated.If creating a new HLRC ReST API call, consider creating new actions instead of reusing server actions.protected <Req extends org.elasticsearch.action.ActionRequest, Resp>
org.elasticsearch.client.CancellableperformRequestAsyncAndParseEntity(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser, org.elasticsearch.action.ActionListener<Resp> listener, java.util.Set<java.lang.Integer> ignores)
Deprecated.If creating a new HLRC ReST API call, consider creating new actions instead of reusing server actions.protected <Req extends Validatable, Resp>
org.elasticsearch.client.CancellableperformRequestAsyncAndParseOptionalEntity(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser, org.elasticsearch.action.ActionListener<java.util.Optional<Resp>> listener)
Asynchronous request which returns emptyOptional
s in the case of 404s or parses entity into an Optionalboolean
ping(org.elasticsearch.client.RequestOptions options)
Pings the remote Elasticsearch cluster and returns true if the ping succeeded, false otherwiseorg.elasticsearch.action.support.master.AcknowledgedResponse
putScript(org.elasticsearch.action.admin.cluster.storedscripts.PutStoredScriptRequest putStoredScriptRequest, org.elasticsearch.client.RequestOptions options)
Puts an stored script using the Scripting API.org.elasticsearch.client.Cancellable
putScriptAsync(org.elasticsearch.action.admin.cluster.storedscripts.PutStoredScriptRequest putStoredScriptRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.support.master.AcknowledgedResponse> listener)
Asynchronously puts an stored script using the Scripting API.org.elasticsearch.index.rankeval.RankEvalResponse
rankEval(org.elasticsearch.index.rankeval.RankEvalRequest rankEvalRequest, org.elasticsearch.client.RequestOptions options)
Executes a request using the Ranking Evaluation API.org.elasticsearch.client.Cancellable
rankEvalAsync(org.elasticsearch.index.rankeval.RankEvalRequest rankEvalRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.index.rankeval.RankEvalResponse> listener)
Asynchronously executes a request using the Ranking Evaluation API.org.elasticsearch.index.reindex.BulkByScrollResponse
reindex(org.elasticsearch.index.reindex.ReindexRequest reindexRequest, org.elasticsearch.client.RequestOptions options)
Executes a reindex request.org.elasticsearch.client.Cancellable
reindexAsync(org.elasticsearch.index.reindex.ReindexRequest reindexRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.index.reindex.BulkByScrollResponse> listener)
Asynchronously executes a reindex request.org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse
reindexRethrottle(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options)
Executes a reindex rethrottling request.org.elasticsearch.client.Cancellable
reindexRethrottleAsync(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse> listener)
Executes a reindex rethrottling request.RollupClient
rollup()
Provides methods for accessing the Elastic Licensed Rollup APIs that are shipped with the default distribution of Elasticsearch.org.elasticsearch.action.search.SearchResponse
scroll(org.elasticsearch.action.search.SearchScrollRequest searchScrollRequest, org.elasticsearch.client.RequestOptions options)
Executes a search using the Search Scroll API.org.elasticsearch.client.Cancellable
scrollAsync(org.elasticsearch.action.search.SearchScrollRequest searchScrollRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.SearchResponse> listener)
Asynchronously executes a search using the Search Scroll API.org.elasticsearch.action.search.SearchResponse
search(org.elasticsearch.action.search.SearchRequest searchRequest, org.elasticsearch.client.RequestOptions options)
Executes a search request using the Search API.org.elasticsearch.client.Cancellable
searchAsync(org.elasticsearch.action.search.SearchRequest searchRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.SearchResponse> listener)
Asynchronously executes a search using the Search API.org.elasticsearch.action.search.SearchResponse
searchScroll(org.elasticsearch.action.search.SearchScrollRequest searchScrollRequest, org.elasticsearch.client.RequestOptions options)
Deprecated.usescroll(SearchScrollRequest, RequestOptions)
insteadorg.elasticsearch.client.Cancellable
searchScrollAsync(org.elasticsearch.action.search.SearchScrollRequest searchScrollRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.SearchResponse> listener)
Deprecated.org.elasticsearch.script.mustache.SearchTemplateResponse
searchTemplate(org.elasticsearch.script.mustache.SearchTemplateRequest searchTemplateRequest, org.elasticsearch.client.RequestOptions options)
Executes a request using the Search Template API.org.elasticsearch.client.Cancellable
searchTemplateAsync(org.elasticsearch.script.mustache.SearchTemplateRequest searchTemplateRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.script.mustache.SearchTemplateResponse> listener)
Asynchronously executes a request using the Search Template API.SecurityClient
security()
Provides methods for accessing the Elastic Licensed Security APIs that are shipped with the Elastic Stack distribution of Elasticsearch.SnapshotClient
snapshot()
Provides aSnapshotClient
which can be used to access the Snapshot API.TaskSubmissionResponse
submitDeleteByQueryTask(org.elasticsearch.index.reindex.DeleteByQueryRequest deleteByQueryRequest, org.elasticsearch.client.RequestOptions options)
Submits a delete by query task See Delete By Query API on elastic.coTaskSubmissionResponse
submitReindexTask(org.elasticsearch.index.reindex.ReindexRequest reindexRequest, org.elasticsearch.client.RequestOptions options)
Submits a reindex task.TasksClient
tasks()
Provides aTasksClient
which can be used to access the Tasks API.TermVectorsResponse
termvectors(TermVectorsRequest request, org.elasticsearch.client.RequestOptions options)
Calls the Term Vectors API See Term Vectors API on elastic.coorg.elasticsearch.client.Cancellable
termvectorsAsync(TermVectorsRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<TermVectorsResponse> listener)
Asynchronously calls the Term Vectors API See Term Vectors API on elastic.coTransformClient
transform()
Provides methods for accessing the Elastic Licensed Data Frame APIs that are shipped with the Elastic Stack distribution of Elasticsearch.org.elasticsearch.action.update.UpdateResponse
update(org.elasticsearch.action.update.UpdateRequest updateRequest, org.elasticsearch.client.RequestOptions options)
Updates a document using the Update API.org.elasticsearch.client.Cancellable
updateAsync(org.elasticsearch.action.update.UpdateRequest updateRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.update.UpdateResponse> listener)
Asynchronously updates a document using the Update API.org.elasticsearch.index.reindex.BulkByScrollResponse
updateByQuery(org.elasticsearch.index.reindex.UpdateByQueryRequest updateByQueryRequest, org.elasticsearch.client.RequestOptions options)
Executes a update by query request.org.elasticsearch.client.Cancellable
updateByQueryAsync(org.elasticsearch.index.reindex.UpdateByQueryRequest updateByQueryRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.index.reindex.BulkByScrollResponse> listener)
Asynchronously executes an update by query request.org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse
updateByQueryRethrottle(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options)
Executes a update by query rethrottle request.org.elasticsearch.client.Cancellable
updateByQueryRethrottleAsync(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse> listener)
Asynchronously execute an update by query rethrottle request.WatcherClient
watcher()
Provides methods for accessing the Elastic Licensed Watcher APIs that are shipped with the default distribution of Elasticsearch.XPackClient
xpack()
Provides methods for accessing the Elastic Licensed X-Pack Info and Usage APIs that are shipped with the default distribution of Elasticsearch.
-
Constructor Details
-
RestHighLevelClient
public RestHighLevelClient(org.elasticsearch.client.RestClientBuilder restClientBuilder)Creates aRestHighLevelClient
given the low levelRestClientBuilder
that allows to build theRestClient
to be used to perform requests. -
RestHighLevelClient
protected RestHighLevelClient(org.elasticsearch.client.RestClientBuilder restClientBuilder, java.util.List<org.elasticsearch.common.xcontent.NamedXContentRegistry.Entry> namedXContentEntries)Creates aRestHighLevelClient
given the low levelRestClientBuilder
that allows to build theRestClient
to be used to perform requests and parsers for custom response sections added to Elasticsearch through plugins. -
RestHighLevelClient
protected RestHighLevelClient(org.elasticsearch.client.RestClient restClient, org.elasticsearch.common.CheckedConsumer<org.elasticsearch.client.RestClient,java.io.IOException> doClose, java.util.List<org.elasticsearch.common.xcontent.NamedXContentRegistry.Entry> namedXContentEntries)Creates aRestHighLevelClient
given the low levelRestClient
that it should use to perform requests and a list of entries that allow to parse custom response sections added to Elasticsearch through plugins. This constructor can be called by subclasses in case an externally created low-level REST client needs to be provided. The consumer argument allows to control what needs to be done when theclose()
method is called. Also subclasses can provide parsers for custom response sections added to Elasticsearch through plugins.
-
-
Method Details
-
getLowLevelClient
public final org.elasticsearch.client.RestClient getLowLevelClient()Returns the low-level client that the current high-level client instance is using to perform requests -
close
public final void close() throws java.io.IOException- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Throws:
java.io.IOException
-
indices
Provides anIndicesClient
which can be used to access the Indices API. See Indices API on elastic.co -
cluster
Provides aClusterClient
which can be used to access the Cluster API. See Cluster API on elastic.co -
ingest
Provides aIngestClient
which can be used to access the Ingest API. See Ingest API on elastic.co -
snapshot
Provides aSnapshotClient
which can be used to access the Snapshot API. See Snapshot API on elastic.co -
rollup
Provides methods for accessing the Elastic Licensed Rollup APIs that are shipped with the default distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the Watcher APIs on elastic.co for more information.
-
ccr
Provides methods for accessing the Elastic Licensed CCR APIs that are shipped with the Elastic Stack distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the CCR APIs on elastic.co for more information.
- Returns:
- the client wrapper for making CCR API calls
-
tasks
Provides aTasksClient
which can be used to access the Tasks API. See Task Management API on elastic.co -
xpack
Provides methods for accessing the Elastic Licensed X-Pack Info and Usage APIs that are shipped with the default distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the Info APIs on elastic.co for more information.
-
watcher
Provides methods for accessing the Elastic Licensed Watcher APIs that are shipped with the default distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the Watcher APIs on elastic.co for more information.
-
graph
Provides methods for accessing the Elastic Licensed Graph explore API that is shipped with the default distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the Graph API on elastic.co for more information.
-
license
Provides methods for accessing the Elastic Licensed Licensing APIs that are shipped with the default distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the Licensing APIs on elastic.co for more information.
-
indexLifecycle
A wrapper for theRestHighLevelClient
that provides methods for accessing the Elastic Index Lifecycle APIs.See the X-Pack APIs on elastic.co for more information.
-
asyncSearch
A wrapper for theRestHighLevelClient
that provides methods for accessing the Elastic Index Async Search APIs.See the X-Pack APIs on elastic.co for more information.
-
migration
Provides methods for accessing the Elastic Licensed Migration APIs that are shipped with the default distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the Migration APIs on elastic.co for more information.
-
machineLearning
Provides methods for accessing the Elastic Licensed Machine Learning APIs that are shipped with the Elastic Stack distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the Machine Learning APIs on elastic.co for more information.
- Returns:
- the client wrapper for making Machine Learning API calls
-
security
Provides methods for accessing the Elastic Licensed Security APIs that are shipped with the Elastic Stack distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the Security APIs on elastic.co for more information.
- Returns:
- the client wrapper for making Security API calls
-
transform
Provides methods for accessing the Elastic Licensed Data Frame APIs that are shipped with the Elastic Stack distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the Transform APIs on elastic.co for more information.
- Returns:
- the client wrapper for making Data Frame API calls
-
enrich
-
eql
Provides methods for accessing the Elastic EQL APIs that are shipped with the Elastic Stack distribution of Elasticsearch. All of these APIs will 404 if run against the OSS distribution of Elasticsearch.See the EQL APIs on elastic.co for more information.
- Returns:
- the client wrapper for making Data Frame API calls
-
bulk
public final org.elasticsearch.action.bulk.BulkResponse bulk(org.elasticsearch.action.bulk.BulkRequest bulkRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a bulk request using the Bulk API. See Bulk API on elastic.co- Parameters:
bulkRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
bulkAsync
public final org.elasticsearch.client.Cancellable bulkAsync(org.elasticsearch.action.bulk.BulkRequest bulkRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.bulk.BulkResponse> listener)Asynchronously executes a bulk request using the Bulk API. See Bulk API on elastic.co- Parameters:
bulkRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
reindex
public final org.elasticsearch.index.reindex.BulkByScrollResponse reindex(org.elasticsearch.index.reindex.ReindexRequest reindexRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a reindex request. See Reindex API on elastic.co- Parameters:
reindexRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
submitReindexTask
public final TaskSubmissionResponse submitReindexTask(org.elasticsearch.index.reindex.ReindexRequest reindexRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionSubmits a reindex task. See Reindex API on elastic.co- Parameters:
reindexRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the submission response
- Throws:
java.io.IOException
-
reindexAsync
public final org.elasticsearch.client.Cancellable reindexAsync(org.elasticsearch.index.reindex.ReindexRequest reindexRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.index.reindex.BulkByScrollResponse> listener)Asynchronously executes a reindex request. See Reindex API on elastic.co- Parameters:
reindexRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
updateByQuery
public final org.elasticsearch.index.reindex.BulkByScrollResponse updateByQuery(org.elasticsearch.index.reindex.UpdateByQueryRequest updateByQueryRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a update by query request. See Update By Query API on elastic.co- Parameters:
updateByQueryRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
updateByQueryAsync
public final org.elasticsearch.client.Cancellable updateByQueryAsync(org.elasticsearch.index.reindex.UpdateByQueryRequest updateByQueryRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.index.reindex.BulkByScrollResponse> listener)Asynchronously executes an update by query request. See Update By Query API on elastic.co- Parameters:
updateByQueryRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
deleteByQuery
public final org.elasticsearch.index.reindex.BulkByScrollResponse deleteByQuery(org.elasticsearch.index.reindex.DeleteByQueryRequest deleteByQueryRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a delete by query request. See Delete By Query API on elastic.co- Parameters:
deleteByQueryRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
submitDeleteByQueryTask
public final TaskSubmissionResponse submitDeleteByQueryTask(org.elasticsearch.index.reindex.DeleteByQueryRequest deleteByQueryRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionSubmits a delete by query task See Delete By Query API on elastic.co- Parameters:
deleteByQueryRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the submission response
- Throws:
java.io.IOException
-
deleteByQueryAsync
public final org.elasticsearch.client.Cancellable deleteByQueryAsync(org.elasticsearch.index.reindex.DeleteByQueryRequest deleteByQueryRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.index.reindex.BulkByScrollResponse> listener)Asynchronously executes a delete by query request. See Delete By Query API on elastic.co- Parameters:
deleteByQueryRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
deleteByQueryRethrottle
public final org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse deleteByQueryRethrottle(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a delete by query rethrottle request. See Delete By Query API on elastic.co- Parameters:
rethrottleRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
deleteByQueryRethrottleAsync
public final org.elasticsearch.client.Cancellable deleteByQueryRethrottleAsync(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse> listener)Asynchronously execute an delete by query rethrottle request. See Delete By Query API on elastic.co- Parameters:
rethrottleRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
updateByQueryRethrottle
public final org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse updateByQueryRethrottle(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a update by query rethrottle request. See Update By Query API on elastic.co- Parameters:
rethrottleRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
updateByQueryRethrottleAsync
public final org.elasticsearch.client.Cancellable updateByQueryRethrottleAsync(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse> listener)Asynchronously execute an update by query rethrottle request. See Update By Query API on elastic.co- Parameters:
rethrottleRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
reindexRethrottle
public final org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse reindexRethrottle(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a reindex rethrottling request. See the Reindex rethrottling API on elastic.co- Parameters:
rethrottleRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
reindexRethrottleAsync
public final org.elasticsearch.client.Cancellable reindexRethrottleAsync(RethrottleRequest rethrottleRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse> listener)Executes a reindex rethrottling request. See the Reindex rethrottling API on elastic.co- Parameters:
rethrottleRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
ping
public final boolean ping(org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionPings the remote Elasticsearch cluster and returns true if the ping succeeded, false otherwise- Parameters:
options
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
true
if the ping succeeded, false otherwise- Throws:
java.io.IOException
-
info
public final MainResponse info(org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionGet the cluster info otherwise provided when sending an HTTP request to '/'- Parameters:
options
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
get
public final org.elasticsearch.action.get.GetResponse get(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionRetrieves a document by id using the Get API. See Get API on elastic.co- Parameters:
getRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
getAsync
public final org.elasticsearch.client.Cancellable getAsync(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.get.GetResponse> listener)Asynchronously retrieves a document by id using the Get API. See Get API on elastic.co- Parameters:
getRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
multiGet
@Deprecated public final org.elasticsearch.action.get.MultiGetResponse multiGet(org.elasticsearch.action.get.MultiGetRequest multiGetRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionDeprecated.usemget(MultiGetRequest, RequestOptions)
insteadRetrieves multiple documents by id using the Multi Get API. See Multi Get API on elastic.co- Parameters:
multiGetRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
mget
public final org.elasticsearch.action.get.MultiGetResponse mget(org.elasticsearch.action.get.MultiGetRequest multiGetRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionRetrieves multiple documents by id using the Multi Get API. See Multi Get API on elastic.co- Parameters:
multiGetRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
multiGetAsync
@Deprecated public final org.elasticsearch.client.Cancellable multiGetAsync(org.elasticsearch.action.get.MultiGetRequest multiGetRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.get.MultiGetResponse> listener)Deprecated.Asynchronously retrieves multiple documents by id using the Multi Get API. See Multi Get API on elastic.co- Parameters:
multiGetRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
mgetAsync
public final org.elasticsearch.client.Cancellable mgetAsync(org.elasticsearch.action.get.MultiGetRequest multiGetRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.get.MultiGetResponse> listener)Asynchronously retrieves multiple documents by id using the Multi Get API. See Multi Get API on elastic.co- Parameters:
multiGetRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
exists
public final boolean exists(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionChecks for the existence of a document. Returns true if it exists, false otherwise. See Get API on elastic.co- Parameters:
getRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
true
if the document exists,false
otherwise- Throws:
java.io.IOException
-
existsAsync
public final org.elasticsearch.client.Cancellable existsAsync(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<java.lang.Boolean> listener)Asynchronously checks for the existence of a document. Returns true if it exists, false otherwise. See Get API on elastic.co- Parameters:
getRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
existsSource
@Deprecated public boolean existsSource(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionDeprecated.useexistsSource(GetSourceRequest, RequestOptions)
insteadChecks for the existence of a document with a "_source" field. Returns true if it exists, false otherwise. See Source exists API on elastic.co- Parameters:
getRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
true
if the document and _source field exists,false
otherwise- Throws:
java.io.IOException
-
existsSourceAsync
@Deprecated public final org.elasticsearch.client.Cancellable existsSourceAsync(org.elasticsearch.action.get.GetRequest getRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<java.lang.Boolean> listener)Deprecated.Asynchronously checks for the existence of a document with a "_source" field. Returns true if it exists, false otherwise. See Source exists API on elastic.co- Parameters:
getRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
existsSource
public boolean existsSource(GetSourceRequest getSourceRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionChecks for the existence of a document with a "_source" field. Returns true if it exists, false otherwise. See Source exists API on elastic.co- Parameters:
getSourceRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
true
if the document and _source field exists,false
otherwise- Throws:
java.io.IOException
-
existsSourceAsync
public final org.elasticsearch.client.Cancellable existsSourceAsync(GetSourceRequest getSourceRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<java.lang.Boolean> listener)Asynchronously checks for the existence of a document with a "_source" field. Returns true if it exists, false otherwise. See Source exists API on elastic.co- Parameters:
getSourceRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
getSource
public GetSourceResponse getSource(GetSourceRequest getSourceRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionRetrieves the source field only of a document using GetSource API. See Get Source API on elastic.co- Parameters:
getSourceRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
getSourceAsync
public final org.elasticsearch.client.Cancellable getSourceAsync(GetSourceRequest getSourceRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<GetSourceResponse> listener)Asynchronously retrieves the source field only of a document using GetSource API. See Get Source API on elastic.co- Parameters:
getSourceRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
index
public final org.elasticsearch.action.index.IndexResponse index(org.elasticsearch.action.index.IndexRequest indexRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionIndex a document using the Index API. See Index API on elastic.co- Parameters:
indexRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
indexAsync
public final org.elasticsearch.client.Cancellable indexAsync(org.elasticsearch.action.index.IndexRequest indexRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.index.IndexResponse> listener)Asynchronously index a document using the Index API. See Index API on elastic.co- Parameters:
indexRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
count
public final CountResponse count(CountRequest countRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a count request using the Count API. See Count API on elastic.co- Parameters:
countRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
countAsync
public final org.elasticsearch.client.Cancellable countAsync(CountRequest countRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<CountResponse> listener)Asynchronously executes a count request using the Count API. See Count API on elastic.co- Parameters:
countRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
update
public final org.elasticsearch.action.update.UpdateResponse update(org.elasticsearch.action.update.UpdateRequest updateRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionUpdates a document using the Update API. See Update API on elastic.co- Parameters:
updateRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
updateAsync
public final org.elasticsearch.client.Cancellable updateAsync(org.elasticsearch.action.update.UpdateRequest updateRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.update.UpdateResponse> listener)Asynchronously updates a document using the Update API. See Update API on elastic.co- Parameters:
updateRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
delete
public final org.elasticsearch.action.delete.DeleteResponse delete(org.elasticsearch.action.delete.DeleteRequest deleteRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionDeletes a document by id using the Delete API. See Delete API on elastic.co- Parameters:
deleteRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
deleteAsync
public final org.elasticsearch.client.Cancellable deleteAsync(org.elasticsearch.action.delete.DeleteRequest deleteRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.delete.DeleteResponse> listener)Asynchronously deletes a document by id using the Delete API. See Delete API on elastic.co- Parameters:
deleteRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
search
public final org.elasticsearch.action.search.SearchResponse search(org.elasticsearch.action.search.SearchRequest searchRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a search request using the Search API. See Search API on elastic.co- Parameters:
searchRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
searchAsync
public final org.elasticsearch.client.Cancellable searchAsync(org.elasticsearch.action.search.SearchRequest searchRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.SearchResponse> listener)Asynchronously executes a search using the Search API. See Search API on elastic.co- Parameters:
searchRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
multiSearch
@Deprecated public final org.elasticsearch.action.search.MultiSearchResponse multiSearch(org.elasticsearch.action.search.MultiSearchRequest multiSearchRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionDeprecated.usemsearch(MultiSearchRequest, RequestOptions)
insteadExecutes a multi search using the msearch API. See Multi search API on elastic.co- Parameters:
multiSearchRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
msearch
public final org.elasticsearch.action.search.MultiSearchResponse msearch(org.elasticsearch.action.search.MultiSearchRequest multiSearchRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a multi search using the msearch API. See Multi search API on elastic.co- Parameters:
multiSearchRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
multiSearchAsync
@Deprecated public final org.elasticsearch.client.Cancellable multiSearchAsync(org.elasticsearch.action.search.MultiSearchRequest searchRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.MultiSearchResponse> listener)Deprecated.Asynchronously executes a multi search using the msearch API. See Multi search API on elastic.co- Parameters:
searchRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
msearchAsync
public final org.elasticsearch.client.Cancellable msearchAsync(org.elasticsearch.action.search.MultiSearchRequest searchRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.MultiSearchResponse> listener)Asynchronously executes a multi search using the msearch API. See Multi search API on elastic.co- Parameters:
searchRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
searchScroll
@Deprecated public final org.elasticsearch.action.search.SearchResponse searchScroll(org.elasticsearch.action.search.SearchScrollRequest searchScrollRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionDeprecated.usescroll(SearchScrollRequest, RequestOptions)
insteadExecutes a search using the Search Scroll API. See Search Scroll API on elastic.co- Parameters:
searchScrollRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
scroll
public final org.elasticsearch.action.search.SearchResponse scroll(org.elasticsearch.action.search.SearchScrollRequest searchScrollRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a search using the Search Scroll API. See Search Scroll API on elastic.co- Parameters:
searchScrollRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
searchScrollAsync
@Deprecated public final org.elasticsearch.client.Cancellable searchScrollAsync(org.elasticsearch.action.search.SearchScrollRequest searchScrollRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.SearchResponse> listener)Deprecated.Asynchronously executes a search using the Search Scroll API. See Search Scroll API on elastic.co- Parameters:
searchScrollRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
scrollAsync
public final org.elasticsearch.client.Cancellable scrollAsync(org.elasticsearch.action.search.SearchScrollRequest searchScrollRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.SearchResponse> listener)Asynchronously executes a search using the Search Scroll API. See Search Scroll API on elastic.co- Parameters:
searchScrollRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
clearScroll
public final org.elasticsearch.action.search.ClearScrollResponse clearScroll(org.elasticsearch.action.search.ClearScrollRequest clearScrollRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionClears one or more scroll ids using the Clear Scroll API. See Clear Scroll API on elastic.co- Parameters:
clearScrollRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
clearScrollAsync
public final org.elasticsearch.client.Cancellable clearScrollAsync(org.elasticsearch.action.search.ClearScrollRequest clearScrollRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.search.ClearScrollResponse> listener)Asynchronously clears one or more scroll ids using the Clear Scroll API. See Clear Scroll API on elastic.co- Parameters:
clearScrollRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
searchTemplate
public final org.elasticsearch.script.mustache.SearchTemplateResponse searchTemplate(org.elasticsearch.script.mustache.SearchTemplateRequest searchTemplateRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a request using the Search Template API. See Search Template API on elastic.co.- Parameters:
searchTemplateRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
searchTemplateAsync
public final org.elasticsearch.client.Cancellable searchTemplateAsync(org.elasticsearch.script.mustache.SearchTemplateRequest searchTemplateRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.script.mustache.SearchTemplateResponse> listener)Asynchronously executes a request using the Search Template API. See Search Template API on elastic.co.- Returns:
- cancellable that may be used to cancel the request
-
explain
public final org.elasticsearch.action.explain.ExplainResponse explain(org.elasticsearch.action.explain.ExplainRequest explainRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a request using the Explain API. See Explain API on elastic.co- Parameters:
explainRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
explainAsync
public final org.elasticsearch.client.Cancellable explainAsync(org.elasticsearch.action.explain.ExplainRequest explainRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.explain.ExplainResponse> listener)Asynchronously executes a request using the Explain API. See Explain API on elastic.co- Parameters:
explainRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
termvectors
public final TermVectorsResponse termvectors(TermVectorsRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionCalls the Term Vectors API See Term Vectors API on elastic.co- Parameters:
request
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Throws:
java.io.IOException
-
termvectorsAsync
public final org.elasticsearch.client.Cancellable termvectorsAsync(TermVectorsRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<TermVectorsResponse> listener)Asynchronously calls the Term Vectors API See Term Vectors API on elastic.co- Parameters:
request
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
mtermvectors
public final MultiTermVectorsResponse mtermvectors(MultiTermVectorsRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionCalls the Multi Term Vectors API See Multi Term Vectors API on elastic.co- Parameters:
request
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Throws:
java.io.IOException
-
mtermvectorsAsync
public final org.elasticsearch.client.Cancellable mtermvectorsAsync(MultiTermVectorsRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<MultiTermVectorsResponse> listener)Asynchronously calls the Multi Term Vectors API See Multi Term Vectors API on elastic.co- Parameters:
request
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
rankEval
public final org.elasticsearch.index.rankeval.RankEvalResponse rankEval(org.elasticsearch.index.rankeval.RankEvalRequest rankEvalRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a request using the Ranking Evaluation API. See Ranking Evaluation API on elastic.co- Parameters:
rankEvalRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
msearchTemplate
public final org.elasticsearch.script.mustache.MultiSearchTemplateResponse msearchTemplate(org.elasticsearch.script.mustache.MultiSearchTemplateRequest multiSearchTemplateRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a request using the Multi Search Template API. See Multi Search Template API on elastic.co.- Throws:
java.io.IOException
-
msearchTemplateAsync
public final org.elasticsearch.client.Cancellable msearchTemplateAsync(org.elasticsearch.script.mustache.MultiSearchTemplateRequest multiSearchTemplateRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.script.mustache.MultiSearchTemplateResponse> listener)Asynchronously executes a request using the Multi Search Template API See Multi Search Template API on elastic.co.- Returns:
- cancellable that may be used to cancel the request
-
rankEvalAsync
public final org.elasticsearch.client.Cancellable rankEvalAsync(org.elasticsearch.index.rankeval.RankEvalRequest rankEvalRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.index.rankeval.RankEvalResponse> listener)Asynchronously executes a request using the Ranking Evaluation API. See Ranking Evaluation API on elastic.co- Parameters:
rankEvalRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
fieldCaps
public final org.elasticsearch.action.fieldcaps.FieldCapabilitiesResponse fieldCaps(org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequest fieldCapabilitiesRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes a request using the Field Capabilities API. See Field Capabilities API on elastic.co.- Parameters:
fieldCapabilitiesRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
getScript
public org.elasticsearch.action.admin.cluster.storedscripts.GetStoredScriptResponse getScript(org.elasticsearch.action.admin.cluster.storedscripts.GetStoredScriptRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionGet stored script by id. See How to use scripts on elastic.co- Parameters:
request
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
getScriptAsync
public org.elasticsearch.client.Cancellable getScriptAsync(org.elasticsearch.action.admin.cluster.storedscripts.GetStoredScriptRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.admin.cluster.storedscripts.GetStoredScriptResponse> listener)Asynchronously get stored script by id. See How to use scripts on elastic.co- Parameters:
request
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
deleteScript
public org.elasticsearch.action.support.master.AcknowledgedResponse deleteScript(org.elasticsearch.action.admin.cluster.storedscripts.DeleteStoredScriptRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionDelete stored script by id. See How to use scripts on elastic.co- Parameters:
request
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
deleteScriptAsync
public org.elasticsearch.client.Cancellable deleteScriptAsync(org.elasticsearch.action.admin.cluster.storedscripts.DeleteStoredScriptRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.support.master.AcknowledgedResponse> listener)Asynchronously delete stored script by id. See How to use scripts on elastic.co- Parameters:
request
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
putScript
public org.elasticsearch.action.support.master.AcknowledgedResponse putScript(org.elasticsearch.action.admin.cluster.storedscripts.PutStoredScriptRequest putStoredScriptRequest, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionPuts an stored script using the Scripting API. See Scripting API on elastic.co- Parameters:
putStoredScriptRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
-
putScriptAsync
public org.elasticsearch.client.Cancellable putScriptAsync(org.elasticsearch.action.admin.cluster.storedscripts.PutStoredScriptRequest putStoredScriptRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.support.master.AcknowledgedResponse> listener)Asynchronously puts an stored script using the Scripting API. See Scripting API on elastic.co- Parameters:
putStoredScriptRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
fieldCapsAsync
public final org.elasticsearch.client.Cancellable fieldCapsAsync(org.elasticsearch.action.fieldcaps.FieldCapabilitiesRequest fieldCapabilitiesRequest, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<org.elasticsearch.action.fieldcaps.FieldCapabilitiesResponse> listener)Asynchronously executes a request using the Field Capabilities API. See Field Capabilities API on elastic.co.- Parameters:
fieldCapabilitiesRequest
- the requestoptions
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customizedlistener
- the listener to be notified upon request completion- Returns:
- cancellable that may be used to cancel the request
-
performRequestAndParseEntity
@Deprecated protected final <Req extends org.elasticsearch.action.ActionRequest, Resp> Resp performRequestAndParseEntity(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser, java.util.Set<java.lang.Integer> ignores) throws java.io.IOExceptionDeprecated.If creating a new HLRC ReST API call, consider creating new actions instead of reusing server actions. The Validation layer has been added to the ReST client, and requests should extendValidatable
instead ofActionRequest
.- Throws:
java.io.IOException
-
performRequestAndParseEntity
protected final <Req extends Validatable, Resp> Resp performRequestAndParseEntity(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser, java.util.Set<java.lang.Integer> ignores) throws java.io.IOExceptionDefines a helper method for performing a request and then parsing the returned entity using the provided entityParser.- Throws:
java.io.IOException
-
performRequest
@Deprecated protected final <Req extends org.elasticsearch.action.ActionRequest, Resp> Resp performRequest(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.client.Response,Resp,java.io.IOException> responseConverter, java.util.Set<java.lang.Integer> ignores) throws java.io.IOExceptionDeprecated.If creating a new HLRC ReST API call, consider creating new actions instead of reusing server actions. The Validation layer has been added to the ReST client, and requests should extendValidatable
instead ofActionRequest
.- Throws:
java.io.IOException
-
performRequest
protected final <Req extends Validatable, Resp> Resp performRequest(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.client.Response,Resp,java.io.IOException> responseConverter, java.util.Set<java.lang.Integer> ignores) throws java.io.IOExceptionDefines a helper method for performing a request.- Throws:
java.io.IOException
-
performRequestAndParseOptionalEntity
protected final <Req extends Validatable, Resp> java.util.Optional<Resp> performRequestAndParseOptionalEntity(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser) throws java.io.IOExceptionDefines a helper method for requests that can 404 and in which case will return an empty Optional otherwise tries to parse the response body- Throws:
java.io.IOException
-
performRequestAsyncAndParseEntity
@Deprecated protected final <Req extends org.elasticsearch.action.ActionRequest, Resp> org.elasticsearch.client.Cancellable performRequestAsyncAndParseEntity(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser, org.elasticsearch.action.ActionListener<Resp> listener, java.util.Set<java.lang.Integer> ignores)Deprecated.If creating a new HLRC ReST API call, consider creating new actions instead of reusing server actions. The Validation layer has been added to the ReST client, and requests should extendValidatable
instead ofActionRequest
.- Returns:
- Cancellable instance that may be used to cancel the request
-
performRequestAsyncAndParseEntity
protected final <Req extends Validatable, Resp> org.elasticsearch.client.Cancellable performRequestAsyncAndParseEntity(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser, org.elasticsearch.action.ActionListener<Resp> listener, java.util.Set<java.lang.Integer> ignores)Defines a helper method for asynchronously performing a request.- Returns:
- Cancellable instance that may be used to cancel the request
-
performRequestAsync
@Deprecated protected final <Req extends org.elasticsearch.action.ActionRequest, Resp> org.elasticsearch.client.Cancellable performRequestAsync(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.client.Response,Resp,java.io.IOException> responseConverter, org.elasticsearch.action.ActionListener<Resp> listener, java.util.Set<java.lang.Integer> ignores)Deprecated.If creating a new HLRC ReST API call, consider creating new actions instead of reusing server actions. The Validation layer has been added to the ReST client, and requests should extendValidatable
instead ofActionRequest
.- Returns:
- Cancellable instance that may be used to cancel the request
-
performRequestAsync
protected final <Req extends Validatable, Resp> org.elasticsearch.client.Cancellable performRequestAsync(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.client.Response,Resp,java.io.IOException> responseConverter, org.elasticsearch.action.ActionListener<Resp> listener, java.util.Set<java.lang.Integer> ignores)Defines a helper method for asynchronously performing a request.- Returns:
- Cancellable instance that may be used to cancel the request
-
performRequestAsyncAndParseOptionalEntity
protected final <Req extends Validatable, Resp> org.elasticsearch.client.Cancellable performRequestAsyncAndParseOptionalEntity(Req request, org.elasticsearch.common.CheckedFunction<Req,org.elasticsearch.client.Request,java.io.IOException> requestConverter, org.elasticsearch.client.RequestOptions options, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser, org.elasticsearch.action.ActionListener<java.util.Optional<Resp>> listener)Asynchronous request which returns emptyOptional
s in the case of 404s or parses entity into an Optional- Returns:
- Cancellable instance that may be used to cancel the request
-
parseResponseException
protected final org.elasticsearch.ElasticsearchStatusException parseResponseException(org.elasticsearch.client.ResponseException responseException)Converts aResponseException
obtained from the low level REST client into anElasticsearchException
. If a response body was returned, tries to parse it as an error returned from Elasticsearch. If no response body was returned or anything goes wrong while parsing the error, returns a newElasticsearchStatusException
that wraps the originalResponseException
. The potential exception obtained while parsing is added to the returned exception as a suppressed exception. This method is guaranteed to not throw any exception eventually thrown while parsing. -
parseEntity
protected final <Resp> Resp parseEntity(org.apache.http.HttpEntity entity, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,java.io.IOException> entityParser) throws java.io.IOException- Throws:
java.io.IOException
-
convertExistsResponse
protected static boolean convertExistsResponse(org.elasticsearch.client.Response response)
-