-
Notifications
You must be signed in to change notification settings - Fork 251
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
Simplify RecordBatchReader to use Project.next() #139
Conversation
@@ -18,6 +18,7 @@ | |||
#include <arrow/result.h> | |||
#include <fmt/format.h> | |||
|
|||
#include "lance/arrow/file_lance_ext.h" |
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.
Forgot to push these changes from the last PR.
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.
one nit
cpp/src/lance/io/exec/project.cc
Outdated
std::optional<int64_t> limit; | ||
int64_t offset; | ||
if (scan_options->fragment_scan_options && | ||
scan_options->fragment_scan_options->type_name() == "lance") { |
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.
Let's extract the string check into a util function?
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.
done
No description provided.