Skip to content

Commit c2b5278

Browse files
committed
Remove PipelineExecutionService#executeIndexRequest (#29537)
With the move long ago to execute all single-document indexing requests as bulk indexing request, the method PipelineExecutionService#executeIndexRequest is unused and will never be used in production code. This commit removes this method and cuts over all tests to use PipelineExecutionService#executeBulkRequest.
1 parent c12a424 commit c2b5278

File tree

2 files changed

+151
-152
lines changed

2 files changed

+151
-152
lines changed

server/src/main/java/org/elasticsearch/ingest/PipelineExecutionService.java

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -53,23 +53,6 @@ public PipelineExecutionService(PipelineStore store, ThreadPool threadPool) {
5353
this.threadPool = threadPool;
5454
}
5555

56-
public void executeIndexRequest(IndexRequest request, Consumer<Exception> failureHandler, Consumer<Boolean> completionHandler) {
57-
Pipeline pipeline = getPipeline(request.getPipeline());
58-
threadPool.executor(ThreadPool.Names.INDEX).execute(new AbstractRunnable() {
59-
60-
@Override
61-
public void onFailure(Exception e) {
62-
failureHandler.accept(e);
63-
}
64-
65-
@Override
66-
protected void doRun() throws Exception {
67-
innerExecute(request, pipeline);
68-
completionHandler.accept(true);
69-
}
70-
});
71-
}
72-
7356
public void executeBulkRequest(Iterable<DocWriteRequest> actionRequests,
7457
BiConsumer<IndexRequest, Exception> itemFailureHandler,
7558
Consumer<Exception> completionHandler) {

0 commit comments

Comments
 (0)