test

Author: kkewwei

server/src/main/java/org/opensearch/search/aggregations/bucket/BucketsAggregator.java

@@ -120,7 +120,7 @@ public final void collectBucket(LeafBucketCollector subCollector, int doc, long
      */
     public final void collectExistingBucket(LeafBucketCollector subCollector, int doc, long bucketOrd) throws IOException {
         long docCount = docCountProvider.getDocCount(doc);
-        if (docCounts.increment(bucketOrd, docCount) == docCount) {
+        if (docCounts.increment(bucketOrd, docCount) == docCount) {// 第一次处理
             // We calculate the final number of buckets only during the reduce phase. But we still need to
             // trigger bucket consumer from time to time in order to give it a chance to check available memory and break
             // the execution if we are running out. To achieve that we are passing 0 as a bucket count.

server/src/main/java/org/opensearch/search/aggregations/bucket/nested/NestedAggregator.java

@@ -103,7 +103,7 @@ public class NestedAggregator extends BucketsAggregator implements SingleBucketA
     public LeafBucketCollector getLeafCollector(final LeafReaderContext ctx, final LeafBucketCollector sub) throws IOException {
         IndexReaderContext topLevelContext = ReaderUtil.getTopLevelContext(ctx);
         IndexSearcher searcher = new IndexSearcher(topLevelContext);
-        searcher.setQueryCache(null);
+        searcher.setQueryCache(null);// todo kewei 是否考虑使用 BitFilter
         Weight weight = searcher.createWeight(searcher.rewrite(childFilter), ScoreMode.COMPLETE_NO_SCORES, 1f);
         Scorer childDocsScorer = weight.scorer(ctx);