org.elasticsearch.ingest

Class PipelineExecutionService

java.lang.Object

org.elasticsearch.ingest.PipelineExecutionService

All Implemented Interfaces:

ClusterStateApplier

public class PipelineExecutionService
extends java.lang.Object
implements ClusterStateApplier

Constructor Summary

Constructors

Constructor and Description
PipelineExecutionService(PipelineStore store, ThreadPool threadPool)

Method Summary

Modifier and Type	Method and Description
void	applyClusterState(ClusterChangedEvent event) Called when a new cluster state (ClusterChangedEvent.state() needs to be applied
void	executeBulkRequest(java.lang.Iterable<DocWriteRequest> actionRequests, java.util.function.BiConsumer<IndexRequest,java.lang.Exception> itemFailureHandler, java.util.function.Consumer<java.lang.Exception> completionHandler)
void	executeIndexRequest(IndexRequest request, java.util.function.Consumer<java.lang.Exception> failureHandler, java.util.function.Consumer<java.lang.Boolean> completionHandler)
IngestStats	stats()

Methods inherited from class java.lang.Object

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

Constructor Detail

PipelineExecutionService

public PipelineExecutionService(PipelineStore store,
                                ThreadPool threadPool)

Method Detail

executeIndexRequest

public void executeIndexRequest(IndexRequest request,
                                java.util.function.Consumer<java.lang.Exception> failureHandler,
                                java.util.function.Consumer<java.lang.Boolean> completionHandler)

executeBulkRequest

public void executeBulkRequest(java.lang.Iterable<DocWriteRequest> actionRequests,
                               java.util.function.BiConsumer<IndexRequest,java.lang.Exception> itemFailureHandler,
                               java.util.function.Consumer<java.lang.Exception> completionHandler)

stats

public IngestStats stats()

applyClusterState

public void applyClusterState(ClusterChangedEvent event)

Description copied from interface: ClusterStateApplier

Called when a new cluster state (ClusterChangedEvent.state() needs to be applied

Specified by:

applyClusterState in interface ClusterStateApplier