WARNING: Deprecated in 7.15.0.
The Java REST Client is deprecated in favor of the Java API Client.
Create or update pipeline API
editCreate or update pipeline API
editRequest
editA PutPipelineRequest
requires an id
argument, a source and a XContentType
. The source consists
of a description and a list of Processor
objects.
Optional arguments
editThe following arguments can optionally be provided:
Timeout to wait for the all the nodes to acknowledge the pipeline creation as a |
|
Timeout to wait for the all the nodes to acknowledge the pipeline creation as a |
Synchronous Execution
editAsynchronous Execution
editThe asynchronous execution of a create or update pipeline request requires both
the PutPipelineRequest
instance and an ActionListener
instance to be passed
to the asynchronous method:
The asynchronous method does not block and returns immediately. Once it is
completed the ActionListener
is called back using the onResponse
method
if the execution successfully completed or using the onFailure
method if
it failed.
A typical listener for WritePipelineResponse
looks like:
Response
editThe returned WritePipelineResponse
allows to retrieve information about the executed
operation as follows: