Skip to content

Commit 771e8b5

Browse files
committed
reduce unnecessary proxying in ProcessorBridge
1 parent 0124c5d commit 771e8b5

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

libs/logstash-bridge/src/main/java/org/elasticsearch/logstashbridge/ingest/ProcessorBridge.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,10 @@ default void execute(IngestDocumentBridge ingestDocumentBridge, BiConsumer<Inges
4646
default IngestDocumentBridge execute(IngestDocumentBridge ingestDocumentBridge) throws Exception {
4747
IngestDocument internalSourceIngestDocument = ingestDocumentBridge.toInternal();
4848
IngestDocument internalResultIngestDocument = toInternal().execute(internalSourceIngestDocument);
49+
50+
if (internalResultIngestDocument == internalSourceIngestDocument) {
51+
return ingestDocumentBridge;
52+
}
4953
return IngestDocumentBridge.fromInternalNullable(internalResultIngestDocument);
5054
}
5155

0 commit comments

Comments
 (0)