-
Notifications
You must be signed in to change notification settings - Fork 85
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
Implement copy node rdf #2028
Implement copy node rdf #2028
Conversation
Codecov ReportPatch coverage:
Additional details and impacted files@@ Coverage Diff @@
## master #2028 +/- ##
==========================================
+ Coverage 89.97% 90.08% +0.11%
==========================================
Files 909 919 +10
Lines 32992 33248 +256
==========================================
+ Hits 29685 29953 +268
+ Misses 3307 3295 -12
☔ View full report in Codecov by Sentry. |
@@ -172,6 +193,68 @@ void HashIndexBuilder<T>::flush() { | |||
} | |||
} | |||
|
|||
template<typename T> | |||
void HashIndexBuilder<T>::rehashSlots(slot_id_t primarySlotId) { |
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.
should we try to cover this code path?
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.
Looks like the rdf test dataset doesn't trigger the rehash.
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.
Can we not introduce changes to hash index now? I feel this should be done later in a more careful way.
@@ -86,7 +86,7 @@ void QueryProcessor::decomposePlanIntoTasks( | |||
} break; | |||
case PhysicalOperatorType::READER: { | |||
auto reader = (Reader*)op; | |||
if (reader->getContainsSerial()) { | |||
if (reader->getContainsSerial() || reader->isCopyTurtleFile()) { |
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.
I thought we only need to read in SERIAL mode rather than copy in single thread. If we need to execute in single thread mode I'll refactor this check to front-end
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.
We need to execute in single thread mode due to the special copy codepath (append to hashIndex first, then append to columnChunk).
79b463a
to
f99d35a
Compare
No description provided.