-
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
[ENH] Add sync point to test_filtering + fix issues #2388
Conversation
Reviewer ChecklistPlease leverage this checklist to ensure your code review is thorough before approving Testing, Bugs, Errors, Logs, Documentation
System Compatibility
Quality
|
3520a32
to
463d621
Compare
1dc686a
to
796db34
Compare
@@ -168,7 +169,11 @@ impl BlockDelta { | |||
builder: new_delta, | |||
id: Uuid::new_v4(), | |||
}; | |||
|
|||
if first_iter { |
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.
is there a way to write this without requiring first iter?
@@ -275,14 +275,21 @@ impl<'me, K: ArrowReadableKey<'me> + Into<KeyWrapper>, V: ArrowReadableValue<'me | |||
let target_block_id = self.sparse_index.get_target_block_id(&search_key); | |||
let block = self.get_block(target_block_id).await; | |||
let res = match block { | |||
Some(block) => block.get(prefix, key), | |||
Some(block) => block.get(prefix, key.clone()), |
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 don't need to clone here do we? It wasn't cloning before?
Description of changes
Summarize the changes made by this PR.
Test plan
pytest
for python,yarn test
for js,cargo test
for rustDocumentation Changes
None