In sub agg path collect by converted ordinal, not active index

Signed-off-by: Finn Carroll <[email protected]>
finnegancarroll · Aug 1, 2024 · 5c713c6 · 5c713c6
1 parent 9ab1447
commit 5c713c6
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...main/java/org/opensearch/search/optimization/filterrewrite/CompositeAggregatorBridge.java b/...main/java/org/opensearch/search/optimization/filterrewrite/CompositeAggregatorBridge.java
@@ -55,7 +55,7 @@ public final void tryOptimize(PointValues values, BiConsumer<Long, Long> increme
 
                 try {
                     incrementDocCount.accept(ord, (long) 1);
-                    sub.collect(docID, activeIndex);
+                    sub.collect(docID, ord);
                 } catch ( IOException ioe) {
                     throw new RuntimeException(ioe);
                 }

diff --git a/.../java/org/opensearch/search/optimization/filterrewrite/DateHistogramAggregatorBridge.java b/.../java/org/opensearch/search/optimization/filterrewrite/DateHistogramAggregatorBridge.java
@@ -136,7 +136,7 @@ public void tryOptimize(PointValues values, BiConsumer<Long, Long> incrementDocC
 
                 try {
                     incrementDocCount.accept(ord, (long) 1);
-                    sub.collect(docID, activeIndex);
+                    sub.collect(docID, ord);
                 } catch ( IOException ioe) {
                     throw new RuntimeException(ioe);
                 }

diff --git a/...src/main/java/org/opensearch/search/optimization/filterrewrite/RangeAggregatorBridge.java b/...src/main/java/org/opensearch/search/optimization/filterrewrite/RangeAggregatorBridge.java
@@ -83,7 +83,7 @@ public final void tryOptimize(PointValues values, BiConsumer<Long, Long> increme
 
                 try {
                     incrementDocCount.accept(ord, (long) 1);
-                    sub.collect(docID, activeIndex);
+                    sub.collect(docID, ord);
                 } catch ( IOException ioe) {
                     throw new RuntimeException(ioe);
                 }