Package co.elastic.clients.elasticsearch.ingest

Class ElasticsearchIngestAsyncClient

java.lang.Object

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

co.elastic.clients.elasticsearch.ingest.ElasticsearchIngestAsyncClient

public class ElasticsearchIngestAsyncClient
extends ApiClient<ElasticsearchTransport,ElasticsearchIngestAsyncClient>

Client for the ingest namespace.

Field Summary

Fields inherited from class co.elastic.clients.ApiClient

transport, transportOptions

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<DeletePipelineResponse>	deletePipeline(DeletePipelineRequest request)	Deletes a pipeline.
java.util.concurrent.CompletableFuture<DeletePipelineResponse>	deletePipeline(java.util.function.Function<DeletePipelineRequest.Builder,ObjectBuilder<DeletePipelineRequest>> fn)	Deletes a pipeline.
java.util.concurrent.CompletableFuture<GeoIpStatsResponse>	geoIpStats()	Returns statistical information about geoip databases
java.util.concurrent.CompletableFuture<GetPipelineResponse>	getPipeline()	Returns a pipeline.
java.util.concurrent.CompletableFuture<GetPipelineResponse>	getPipeline(GetPipelineRequest request)	Returns a pipeline.
java.util.concurrent.CompletableFuture<GetPipelineResponse>	getPipeline(java.util.function.Function<GetPipelineRequest.Builder,ObjectBuilder<GetPipelineRequest>> fn)	Returns a pipeline.
java.util.concurrent.CompletableFuture<ProcessorGrokResponse>	processorGrok()	Returns a list of the built-in patterns.
java.util.concurrent.CompletableFuture<PutPipelineResponse>	putPipeline(PutPipelineRequest request)	Creates or updates a pipeline.
java.util.concurrent.CompletableFuture<PutPipelineResponse>	putPipeline(java.util.function.Function<PutPipelineRequest.Builder,ObjectBuilder<PutPipelineRequest>> fn)	Creates or updates a pipeline.
java.util.concurrent.CompletableFuture<SimulateResponse>	simulate()	Allows to simulate a pipeline with example documents.
java.util.concurrent.CompletableFuture<SimulateResponse>	simulate(SimulateRequest request)	Allows to simulate a pipeline with example documents.
java.util.concurrent.CompletableFuture<SimulateResponse>	simulate(java.util.function.Function<SimulateRequest.Builder,ObjectBuilder<SimulateRequest>> fn)	Allows to simulate a pipeline with example documents.
ElasticsearchIngestAsyncClient	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

ElasticsearchIngestAsyncClient

public ElasticsearchIngestAsyncClient(ElasticsearchTransport transport)

ElasticsearchIngestAsyncClient

public ElasticsearchIngestAsyncClient(ElasticsearchTransport transport,
@Nullable
TransportOptions transportOptions)

Method Details

withTransportOptions

public ElasticsearchIngestAsyncClient withTransportOptions(@Nullable
TransportOptions transportOptions)

Description copied from class: ApiClient

Creates a new client with some request options

Specified by:

withTransportOptions in class ApiClient<ElasticsearchTransport,ElasticsearchIngestAsyncClient>

deletePipeline

public java.util.concurrent.CompletableFuture<DeletePipelineResponse> deletePipeline(DeletePipelineRequest request)
                                                                              throws java.io.IOException,
ElasticsearchException

Deletes a pipeline.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

deletePipeline

public final java.util.concurrent.CompletableFuture<DeletePipelineResponse> deletePipeline(java.util.function.Function<DeletePipelineRequest.Builder,ObjectBuilder<DeletePipelineRequest>> fn)
                                                                                    throws java.io.IOException,
ElasticsearchException

Deletes a pipeline.

Parameters:

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

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

geoIpStats

public java.util.concurrent.CompletableFuture<GeoIpStatsResponse> geoIpStats()
                                                                      throws java.io.IOException,
ElasticsearchException

Returns statistical information about geoip databases

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

getPipeline

public java.util.concurrent.CompletableFuture<GetPipelineResponse> getPipeline(GetPipelineRequest request)
                                                                        throws java.io.IOException,
ElasticsearchException

Returns a pipeline.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

getPipeline

public final java.util.concurrent.CompletableFuture<GetPipelineResponse> getPipeline(java.util.function.Function<GetPipelineRequest.Builder,ObjectBuilder<GetPipelineRequest>> fn)
                                                                              throws java.io.IOException,
ElasticsearchException

Returns a pipeline.

Parameters:

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

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

getPipeline

public java.util.concurrent.CompletableFuture<GetPipelineResponse> getPipeline()
                                                                        throws java.io.IOException,
ElasticsearchException

Returns a pipeline.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

processorGrok

public java.util.concurrent.CompletableFuture<ProcessorGrokResponse> processorGrok()
                                                                            throws java.io.IOException,
ElasticsearchException

Returns a list of the built-in patterns.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

putPipeline

public java.util.concurrent.CompletableFuture<PutPipelineResponse> putPipeline(PutPipelineRequest request)
                                                                        throws java.io.IOException,
ElasticsearchException

Creates or updates a pipeline.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

putPipeline

public final java.util.concurrent.CompletableFuture<PutPipelineResponse> putPipeline(java.util.function.Function<PutPipelineRequest.Builder,ObjectBuilder<PutPipelineRequest>> fn)
                                                                              throws java.io.IOException,
ElasticsearchException

Creates or updates a pipeline.

Parameters:

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

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

simulate

public java.util.concurrent.CompletableFuture<SimulateResponse> simulate(SimulateRequest request)
                                                                  throws java.io.IOException,
ElasticsearchException

Allows to simulate a pipeline with example documents.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

simulate

public final java.util.concurrent.CompletableFuture<SimulateResponse> simulate(java.util.function.Function<SimulateRequest.Builder,ObjectBuilder<SimulateRequest>> fn)
                                                                        throws java.io.IOException,
ElasticsearchException

Allows to simulate a pipeline with example documents.

Parameters:

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

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co

simulate

public java.util.concurrent.CompletableFuture<SimulateResponse> simulate()
                                                                  throws java.io.IOException,
ElasticsearchException

Allows to simulate a pipeline with example documents.

Throws:

java.io.IOException

ElasticsearchException

See Also:

Documentation on elastic.co