-
Notifications
You must be signed in to change notification settings - Fork 1.3k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Cleanup some reader/writer logic for raw forward index #11669
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@saurabhd336 We want to handle the above 2 TODOs (add raw index reader for V4 multi-value index)
} | ||
} else { | ||
// TODO: Support V4 MV reader |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
^^
1); | ||
_indexWriter = new VarByteChunkSVForwardIndexWriter(file, compressionType, totalDocs, numDocsPerChunk, | ||
totalMaxLength, writerVersion); | ||
// TODO: Support V4 MV reader |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
^^
Codecov Report
@@ Coverage Diff @@
## master #11669 +/- ##
============================================
- Coverage 63.10% 63.07% -0.03%
+ Complexity 1121 1120 -1
============================================
Files 2343 2343
Lines 125693 125665 -28
Branches 19310 19312 +2
============================================
- Hits 79315 79262 -53
- Misses 40728 40752 +24
- Partials 5650 5651 +1
Flags with carried forward coverage won't be shown. Click here to find out more.
... and 17 files with indirect coverage changes 📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more |
f7f9bae
to
81b77c9
Compare
return dataType.getStoredType() == DataType.STRING | ||
private static String getValidPropertyValue(String value, boolean isMax, DataType storedType) { | ||
String valueWithinLengthLimit = getValueWithinLengthLimit(value, isMax, storedType); | ||
return storedType.getStoredType() == DataType.STRING |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
storedType == DataType.STRING
?
81b77c9
to
4ed3862
Compare
totalMaxLength, writerVersion); | ||
// TODO: Support V4 MV reader | ||
// Currently fall back to V2 for backward compatible | ||
if (writerVersion >= VarByteChunkForwardIndexWriterV4.VERSION) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
just use writerVersion == VarByteChunkForwardIndexWriterV4.VERSION
to be explicit?
} | ||
} | ||
} | ||
SegmentColumnarIndexCreator.addColumnMinMaxValueInfo(_segmentProperties, columnName, String.valueOf(min), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is common and can be moved out of switch case statement?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This cannot be moved because min
and max
has different type for different data type
4ed3862
to
1f60a3f
Compare
This is the preparation for complete V4 support