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

Signed-off-by: Finn Carroll <carrofin@amazon.com>
opensearch-project · 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);
  }