Package co.elastic.clients.elasticsearch.ingest

Class ElasticsearchIngestClient

java.lang.Object

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

co.elastic.clients.elasticsearch.ingest.ElasticsearchIngestClient

public class ElasticsearchIngestClient
extends ApiClient<ElasticsearchTransport,ElasticsearchIngestClient>

Client for the ingest namespace.

Field Summary

Fields inherited from class co.elastic.clients.ApiClient

transport, transportOptions

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
DeletePipelineResponse	deletePipeline(DeletePipelineRequest request)	Deletes a pipeline.
final DeletePipelineResponse	deletePipeline(Function<DeletePipelineRequest.Builder,ObjectBuilder<DeletePipelineRequest>> fn)	Deletes a pipeline.
GeoIpStatsResponse	geoIpStats()	Returns statistical information about geoip databases
GetPipelineResponse	getPipeline()	Returns a pipeline.
GetPipelineResponse	getPipeline(GetPipelineRequest request)	Returns a pipeline.
final GetPipelineResponse	getPipeline(Function<GetPipelineRequest.Builder,ObjectBuilder<GetPipelineRequest>> fn)	Returns a pipeline.
ProcessorGrokResponse	processorGrok()	Returns a list of the built-in patterns.
PutPipelineResponse	putPipeline(PutPipelineRequest request)	Creates or updates a pipeline.
final PutPipelineResponse	putPipeline(Function<PutPipelineRequest.Builder,ObjectBuilder<PutPipelineRequest>> fn)	Creates or updates a pipeline.
SimulateResponse	simulate()	Allows to simulate a pipeline with example documents.
SimulateResponse	simulate(SimulateRequest request)	Allows to simulate a pipeline with example documents.
final SimulateResponse	simulate(Function<SimulateRequest.Builder,ObjectBuilder<SimulateRequest>> fn)	Allows to simulate a pipeline with example documents.
ElasticsearchIngestClient	withTransportOptions(TransportOptions transportOptions)	Creates a new client with some request options

Methods inherited from class co.elastic.clients.ApiClient

_jsonpMapper, _transport, _transportOptions, getDeserializer, withTransportOptions

Methods inherited from class java.lang.Object

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

Constructor Details

ElasticsearchIngestClient

public ElasticsearchIngestClient(ElasticsearchTransport transport)

ElasticsearchIngestClient

public ElasticsearchIngestClient(ElasticsearchTransport transport,
 @Nullable
 TransportOptions transportOptions)

Method Details

withTransportOptions

public ElasticsearchIngestClient withTransportOptions(@Nullable
 TransportOptions transportOptions)

Description copied from class: ApiClient

Creates a new client with some request options

Specified by:

withTransportOptions in class ApiClient<ElasticsearchTransport,ElasticsearchIngestClient>

deletePipeline

public DeletePipelineResponse deletePipeline(DeletePipelineRequest request)
                                      throws IOException,
ElasticsearchException

Deletes a pipeline.

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

deletePipeline

public final DeletePipelineResponse deletePipeline(Function<DeletePipelineRequest.Builder,ObjectBuilder<DeletePipelineRequest>> fn)
                                            throws IOException,
ElasticsearchException

Deletes a pipeline.

Parameters:

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

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

geoIpStats

public GeoIpStatsResponse geoIpStats()
                              throws IOException,
ElasticsearchException

Returns statistical information about geoip databases

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

getPipeline

public GetPipelineResponse getPipeline(GetPipelineRequest request)
                                throws IOException,
ElasticsearchException

Returns a pipeline.

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

getPipeline

public final GetPipelineResponse getPipeline(Function<GetPipelineRequest.Builder,ObjectBuilder<GetPipelineRequest>> fn)
                                      throws IOException,
ElasticsearchException

Returns a pipeline.

Parameters:

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

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

getPipeline

public GetPipelineResponse getPipeline()
                                throws IOException,
ElasticsearchException

Returns a pipeline.

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

processorGrok

public ProcessorGrokResponse processorGrok()
                                    throws IOException,
ElasticsearchException

Returns a list of the built-in patterns.

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

putPipeline

public PutPipelineResponse putPipeline(PutPipelineRequest request)
                                throws IOException,
ElasticsearchException

Creates or updates a pipeline.

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

putPipeline

public final PutPipelineResponse putPipeline(Function<PutPipelineRequest.Builder,ObjectBuilder<PutPipelineRequest>> fn)
                                      throws IOException,
ElasticsearchException

Creates or updates a pipeline.

Parameters:

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

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

simulate

public SimulateResponse simulate(SimulateRequest request)
                          throws IOException,
ElasticsearchException

Allows to simulate a pipeline with example documents.

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

simulate

public final SimulateResponse simulate(Function<SimulateRequest.Builder,ObjectBuilder<SimulateRequest>> fn)
                                throws IOException,
ElasticsearchException

Allows to simulate a pipeline with example documents.

Parameters:

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

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co

simulate

public SimulateResponse simulate()
                          throws IOException,
ElasticsearchException

Allows to simulate a pipeline with example documents.

Throws:

IOException

ElasticsearchException

See Also:

• Documentation on elastic.co