Package org.elasticsearch.client
Class EnrichClient
java.lang.Object
org.elasticsearch.client.EnrichClient
public final class EnrichClient
extends java.lang.Object
A wrapper for the
RestHighLevelClient
that provides methods for
accessing the Elastic enrich related methods
See the X-Pack Enrich Policy APIs on elastic.co for more information.
-
Method Summary
Modifier and Type Method Description AcknowledgedResponse
deletePolicy(DeletePolicyRequest request, org.elasticsearch.client.RequestOptions options)
Executes the delete policy api, which deletes an enrich policy.org.elasticsearch.client.Cancellable
deletePolicyAsync(DeletePolicyRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<AcknowledgedResponse> listener)
Asynchronously executes the delete policy api, which deletes an enrich policy.ExecutePolicyResponse
executePolicy(ExecutePolicyRequest request, org.elasticsearch.client.RequestOptions options)
Executes the execute policy api, which executes an enrich policy.org.elasticsearch.client.Cancellable
executePolicyAsync(ExecutePolicyRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<ExecutePolicyResponse> listener)
Asynchronously executes the execute policy api, which executes an enrich policy.GetPolicyResponse
getPolicy(GetPolicyRequest request, org.elasticsearch.client.RequestOptions options)
Executes the get policy api, which retrieves an enrich policy.org.elasticsearch.client.Cancellable
getPolicyAsync(GetPolicyRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<GetPolicyResponse> listener)
Asynchronously executes the get policy api, which retrieves an enrich policy.AcknowledgedResponse
putPolicy(PutPolicyRequest request, org.elasticsearch.client.RequestOptions options)
Executes the put policy api, which stores an enrich policy.org.elasticsearch.client.Cancellable
putPolicyAsync(PutPolicyRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<AcknowledgedResponse> listener)
Asynchronously executes the put policy api, which stores an enrich policy.StatsResponse
stats(StatsRequest request, org.elasticsearch.client.RequestOptions options)
Executes the enrich stats api, which retrieves enrich related stats.org.elasticsearch.client.Cancellable
statsAsync(StatsRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<StatsResponse> listener)
Asynchronously executes the enrich stats api, which retrieves enrich related stats.
-
Method Details
-
putPolicy
public AcknowledgedResponse putPolicy(PutPolicyRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes the put policy api, which stores an enrich policy. See the docs for more.- Parameters:
request
- thePutPolicyRequest
options
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
- in case there is a problem sending the request or parsing back the response
-
putPolicyAsync
public org.elasticsearch.client.Cancellable putPolicyAsync(PutPolicyRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<AcknowledgedResponse> listener)Asynchronously executes the put policy api, which stores an enrich policy. See the docs for more.- Parameters:
request
- thePutPolicyRequest
options
- 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
-
deletePolicy
public AcknowledgedResponse deletePolicy(DeletePolicyRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes the delete policy api, which deletes an enrich policy. See the docs for more.- Parameters:
request
- theDeletePolicyRequest
options
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
- in case there is a problem sending the request or parsing back the response
-
deletePolicyAsync
public org.elasticsearch.client.Cancellable deletePolicyAsync(DeletePolicyRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<AcknowledgedResponse> listener)Asynchronously executes the delete policy api, which deletes an enrich policy. See the docs for more.- Parameters:
request
- theDeletePolicyRequest
options
- 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
-
getPolicy
public GetPolicyResponse getPolicy(GetPolicyRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes the get policy api, which retrieves an enrich policy. See the docs for more.- Parameters:
request
- thePutPolicyRequest
options
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
- in case there is a problem sending the request or parsing back the response
-
getPolicyAsync
public org.elasticsearch.client.Cancellable getPolicyAsync(GetPolicyRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<GetPolicyResponse> listener)Asynchronously executes the get policy api, which retrieves an enrich policy. See the docs for more.- Parameters:
request
- thePutPolicyRequest
options
- 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
-
stats
public StatsResponse stats(StatsRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes the enrich stats api, which retrieves enrich related stats. See the docs for more.- Parameters:
request
- theStatsRequest
options
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
- in case there is a problem sending the request or parsing back the response
-
statsAsync
public org.elasticsearch.client.Cancellable statsAsync(StatsRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<StatsResponse> listener)Asynchronously executes the enrich stats api, which retrieves enrich related stats. See the docs for more.- Parameters:
request
- theStatsRequest
options
- 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
-
executePolicy
public ExecutePolicyResponse executePolicy(ExecutePolicyRequest request, org.elasticsearch.client.RequestOptions options) throws java.io.IOExceptionExecutes the execute policy api, which executes an enrich policy. See the docs for more.- Parameters:
request
- theExecutePolicyRequest
options
- the request options (e.g. headers), useRequestOptions.DEFAULT
if nothing needs to be customized- Returns:
- the response
- Throws:
java.io.IOException
- in case there is a problem sending the request or parsing back the response
-
executePolicyAsync
public org.elasticsearch.client.Cancellable executePolicyAsync(ExecutePolicyRequest request, org.elasticsearch.client.RequestOptions options, org.elasticsearch.action.ActionListener<ExecutePolicyResponse> listener)Asynchronously executes the execute policy api, which executes an enrich policy. See the docs for more.- Parameters:
request
- theExecutePolicyRequest
options
- 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
-