Package 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	Description
PipelineExecutionService(PipelineStore store, ThreadPool threadPool)

Method Summary

Modifier and Type	Method	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)
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

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