ClusterStateApplier
public class PipelineExecutionService extends java.lang.Object implements ClusterStateApplier
Constructor | Description |
---|---|
PipelineExecutionService(PipelineStore store,
ThreadPool threadPool) |
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() |
public PipelineExecutionService(PipelineStore store, ThreadPool threadPool)
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)
public IngestStats stats()
public void applyClusterState(ClusterChangedEvent event)
ClusterStateApplier
ClusterChangedEvent.state()
needs to be appliedapplyClusterState
in interface ClusterStateApplier