Compute absolute docId in lucene collector
@@ -67,7 +67,9 @@ public class LuceneDocIdCollector implements Collector {
@Override
public void collect(int doc) throws IOException {
- _docIds.add(_docIdTranslator.getPinotDocId(doc));
+ // Compute the absolute lucene docID across
+ // sub-indexes because that's how the lookup table in docIdTranslator is built
+ _docIds.add(_docIdTranslator.getPinotDocId(context.docBase + doc));
}
};
}
