tibrewalpratik17 commented on code in PR #13352:
URL: https://github.com/apache/pinot/pull/13352#discussion_r1634014707
##########
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/readers/CompactedPinotSegmentRecordReader.java:
##########
@@ -36,19 +37,25 @@
public class CompactedPinotSegmentRecordReader implements RecordReader {
private final PinotSegmentRecordReader _pinotSegmentRecordReader;
private final RoaringBitmap _validDocIdsBitmap;
-
+ private final String _deleteRecordColumn;
+ // Reusable generic row to store the next row to return
+ private final GenericRow _nextRow = new GenericRow();
// Valid doc ids iterator
private PeekableIntIterator _validDocIdsIterator;
- // Reusable generic row to store the next row to return
- private GenericRow _nextRow = new GenericRow();
// Flag to mark whether we need to fetch another row
private boolean _nextRowReturned = true;
public CompactedPinotSegmentRecordReader(File indexDir, RoaringBitmap
validDocIds) {
+ this(indexDir, validDocIds, null);
+ }
+
+ public CompactedPinotSegmentRecordReader(File indexDir, RoaringBitmap
validDocIds,
+ @Nullable String deleteRecordColumn) {
Review Comment:
@klsince you can make it an Upsert Compaction task-level config as well if
you want to use this flag flexibly in your cluster. By default, we can disable
it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
