-
Notifications
You must be signed in to change notification settings - Fork 1.2k
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
refactor: Refactor CompactRow and UnsafeRow serializer and deserializer #11840
refactor: Refactor CompactRow and UnsafeRow serializer and deserializer #11840
Conversation
✅ Deploy Preview for meta-velox canceled.
|
void clear() override {} | ||
|
||
protected: | ||
virtual void serializeRanges( |
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.
After this PR, we can unify serializeRanges #11206
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.
@jinchengchenghh LGTM. Thanks for the refactor!
velox/serializers/RowSerializer.h
Outdated
template <class Serializer> | ||
class RowSerializer : public IterativeVectorSerializer { | ||
public: | ||
explicit RowSerializer(StreamArena* streamArena) |
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.
why not directly pass pool here since we don't hold the stream arena?
velox/serializers/RowSerializer.h
Outdated
const std::vector<vector_size_t>& /*rowSize*/) { | ||
size_t offset = 0; | ||
for (auto& range : ranges) { | ||
for (auto i = range.begin; i < range.begin + range.size; ++i) { |
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.
nit: s/i/row/
@xiaoxmeng has imported this pull request. If you are a Meta employee, you can view this diff on Phabricator. |
@xiaoxmeng merged this pull request in aa59678. |
No description provided.