1 files changed, 7 insertions, 0 deletions
diff --git a/core/src/main/java/org/elasticsearch/ingest/core/Pipeline.java b/core/src/main/java/org/elasticsearch/ingest/core/Pipeline.java
index 821a44c0a9..aaae929e0a 100644
--- a/core/src/main/java/org/elasticsearch/ingest/core/Pipeline.java
+++ b/core/src/main/java/org/elasticsearch/ingest/core/Pipeline.java
@@ -69,6 +69,13 @@ public final class Pipeline {
     }
 
     /**
+     * Get the underlying {@link CompoundProcessor} containing the Pipeline's processors
+     */
+    public CompoundProcessor getCompoundProcessor() {
+        return compoundProcessor;
+    }
+
+    /**
      * Unmodifiable list containing each processor that operates on the data.
      */
     public List<Processor> getProcessors() {