Package co.elastic.clients.elasticsearch.enrich

Class ElasticsearchEnrichAsyncClient

java.lang.Object

co.elastic.clients.ApiClient<ElasticsearchTransport,ElasticsearchEnrichAsyncClient>

co.elastic.clients.elasticsearch.enrich.ElasticsearchEnrichAsyncClient

public class ElasticsearchEnrichAsyncClient
extends ApiClient<ElasticsearchTransport,ElasticsearchEnrichAsyncClient>

Client for the enrich namespace.

Field Summary

Fields inherited from class co.elastic.clients.ApiClient

transport, transportOptions

Constructor Summary

Constructors

Constructor	Description
ElasticsearchEnrichAsyncClient(ElasticsearchTransport transport)
ElasticsearchEnrichAsyncClient(ElasticsearchTransport transport, TransportOptions transportOptions)

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<DeletePolicyResponse>	deletePolicy(DeletePolicyRequest request)	Deletes an existing enrich policy and its enrich index.
java.util.concurrent.CompletableFuture<DeletePolicyResponse>	deletePolicy(java.util.function.Function<DeletePolicyRequest.Builder,ObjectBuilder<DeletePolicyRequest>> fn)	Deletes an existing enrich policy and its enrich index.
java.util.concurrent.CompletableFuture<ExecutePolicyResponse>	executePolicy(ExecutePolicyRequest request)	Creates the enrich index for an existing enrich policy.
java.util.concurrent.CompletableFuture<ExecutePolicyResponse>	executePolicy(java.util.function.Function<ExecutePolicyRequest.Builder,ObjectBuilder<ExecutePolicyRequest>> fn)	Creates the enrich index for an existing enrich policy.
java.util.concurrent.CompletableFuture<GetPolicyResponse>	getPolicy()	Gets information about an enrich policy.
java.util.concurrent.CompletableFuture<GetPolicyResponse>	getPolicy(GetPolicyRequest request)	Gets information about an enrich policy.
java.util.concurrent.CompletableFuture<GetPolicyResponse>	getPolicy(java.util.function.Function<GetPolicyRequest.Builder,ObjectBuilder<GetPolicyRequest>> fn)	Gets information about an enrich policy.
java.util.concurrent.CompletableFuture<PutPolicyResponse>	putPolicy(PutPolicyRequest request)	Creates a new enrich policy.
java.util.concurrent.CompletableFuture<PutPolicyResponse>	putPolicy(java.util.function.Function<PutPolicyRequest.Builder,ObjectBuilder<PutPolicyRequest>> fn)	Creates a new enrich policy.
java.util.concurrent.CompletableFuture<EnrichStatsResponse>	stats()	Gets enrich coordinator statistics and information about enrich policies that are currently executing.
ElasticsearchEnrichAsyncClient	withTransportOptions(TransportOptions transportOptions)	Creates a new client with some request options

Methods inherited from class co.elastic.clients.ApiClient

_transport, _transportOptions, getDeserializer

Methods inherited from class java.lang.Object

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

Constructor Details

ElasticsearchEnrichAsyncClient

public ElasticsearchEnrichAsyncClient(ElasticsearchTransport transport)

ElasticsearchEnrichAsyncClient

public ElasticsearchEnrichAsyncClient(ElasticsearchTransport transport,
@Nullable
TransportOptions transportOptions)

Method Details

withTransportOptions

public ElasticsearchEnrichAsyncClient withTransportOptions(@Nullable
TransportOptions transportOptions)

Description copied from class: ApiClient

Creates a new client with some request options

Specified by:

withTransportOptions in class ApiClient<ElasticsearchTransport,ElasticsearchEnrichAsyncClient>

deletePolicy

public java.util.concurrent.CompletableFuture<DeletePolicyResponse> deletePolicy(DeletePolicyRequest request)
                                                                          throws java.io.IOException,
ElasticsearchException

Deletes an existing enrich policy and its enrich index.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

deletePolicy

public final java.util.concurrent.CompletableFuture<DeletePolicyResponse> deletePolicy(java.util.function.Function<DeletePolicyRequest.Builder,ObjectBuilder<DeletePolicyRequest>> fn)
                                                                                throws java.io.IOException,
ElasticsearchException

Deletes an existing enrich policy and its enrich index.

Parameters:

fn - a function that initializes a builder to create the DeletePolicyRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

executePolicy

public java.util.concurrent.CompletableFuture<ExecutePolicyResponse> executePolicy(ExecutePolicyRequest request)
                                                                            throws java.io.IOException,
ElasticsearchException

Creates the enrich index for an existing enrich policy.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

executePolicy

public final java.util.concurrent.CompletableFuture<ExecutePolicyResponse> executePolicy(java.util.function.Function<ExecutePolicyRequest.Builder,ObjectBuilder<ExecutePolicyRequest>> fn)
                                                                                  throws java.io.IOException,
ElasticsearchException

Creates the enrich index for an existing enrich policy.

Parameters:

fn - a function that initializes a builder to create the ExecutePolicyRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

getPolicy

public java.util.concurrent.CompletableFuture<GetPolicyResponse> getPolicy(GetPolicyRequest request)
                                                                    throws java.io.IOException,
ElasticsearchException

Gets information about an enrich policy.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

getPolicy

public final java.util.concurrent.CompletableFuture<GetPolicyResponse> getPolicy(java.util.function.Function<GetPolicyRequest.Builder,ObjectBuilder<GetPolicyRequest>> fn)
                                                                          throws java.io.IOException,
ElasticsearchException

Gets information about an enrich policy.

Parameters:

fn - a function that initializes a builder to create the GetPolicyRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

getPolicy

public java.util.concurrent.CompletableFuture<GetPolicyResponse> getPolicy()
                                                                    throws java.io.IOException,
ElasticsearchException

Gets information about an enrich policy.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

putPolicy

public java.util.concurrent.CompletableFuture<PutPolicyResponse> putPolicy(PutPolicyRequest request)
                                                                    throws java.io.IOException,
ElasticsearchException

Creates a new enrich policy.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

putPolicy

public final java.util.concurrent.CompletableFuture<PutPolicyResponse> putPolicy(java.util.function.Function<PutPolicyRequest.Builder,ObjectBuilder<PutPolicyRequest>> fn)
                                                                          throws java.io.IOException,
ElasticsearchException

Creates a new enrich policy.

Parameters:

fn - a function that initializes a builder to create the PutPolicyRequest

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

stats

public java.util.concurrent.CompletableFuture<EnrichStatsResponse> stats()
                                                                  throws java.io.IOException,
ElasticsearchException

Gets enrich coordinator statistics and information about enrich policies that are currently executing.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co