GromNaN · GromNaN · Nov 6, 2025
diff --git a/src/Builder/Accumulator/AvgAccumulator.php b/src/Builder/Accumulator/AvgAccumulator.php
diff --git a/src/Builder/Accumulator/CountAccumulator.php b/src/Builder/Accumulator/CountAccumulator.php
diff --git a/src/Builder/Accumulator/MaxAccumulator.php b/src/Builder/Accumulator/MaxAccumulator.php
diff --git a/src/Builder/Accumulator/MinAccumulator.php b/src/Builder/Accumulator/MinAccumulator.php
diff --git a/src/Builder/Accumulator/OutputWindowAccumulator.php b/src/Builder/Accumulator/OutputWindowAccumulator.php
diff --git a/src/Builder/Accumulator/SumAccumulator.php b/src/Builder/Accumulator/SumAccumulator.php
diff --git a/src/Builder/Pipeline.php b/src/Builder/Pipeline.php
@@ -57,4 +57,24 @@ public function getIterator(): ArrayIterator
     {
         return new ArrayIterator($this->stages);
     }
+
+    /**
+     * Executes the pipeline locally on the provided documents.
+     * Only for test/local execution purposes.
+     *
+     * @param array $documents Input documents
+     * @return array Resulting documents after pipeline execution
+     */
+    public function processLocally(array $documents): array
+    {
+        $result = $documents;
+        foreach ($this->stages as $stage) {
+            if (method_exists($stage, 'processLocally')) {
+                $result = $stage->processLocally($result);
+            } else {
+                throw new \RuntimeException('Stage does not support local execution: ' . (is_object($stage) ? get_class($stage) : gettype($stage)));
+            }
+        }
+        return $result;
+    }
 }
diff --git a/src/Builder/Stage/FacetStage.php b/src/Builder/Stage/FacetStage.php
diff --git a/src/Builder/Stage/GroupStage.php b/src/Builder/Stage/GroupStage.php
diff --git a/src/Builder/Stage/LimitStage.php b/src/Builder/Stage/LimitStage.php
diff --git a/src/Builder/Stage/MatchStage.php b/src/Builder/Stage/MatchStage.php
diff --git a/src/Builder/Stage/ProjectStage.php b/src/Builder/Stage/ProjectStage.php