-
Notifications
You must be signed in to change notification settings - Fork 0
Switch to the async API and object_store_ffi infra #3
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
base: main
Are you sure you want to change the base?
Conversation
@@ -84,7 +84,24 @@ fi | |||
# Step 3: Run the integration test | |||
print_status "Running integration test..." | |||
echo "==========================================" | |||
if ./integration_test; then | |||
|
|||
# Determine the exact library filename |
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.
what is this
); | ||
|
||
// Async function to initialize stream without getting first batch | ||
export_runtime_op!( |
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.
Consider initializing the stream when it is created. This means we no longer need IcebergResponse
} | ||
|
||
// Helper function to create ArrowBatch from RecordBatch | ||
// TODO: This should be zero-copy... | ||
// TODO: Switch to zero-copy once Arrow.jl supports C API. |
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 op should happen in set_payload
in IcebergBatchResponse
.
src/lib.rs
Outdated
} | ||
} | ||
}, | ||
scan: *mut IcebergScan |
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.
consider implementing a method for IcebergScan so that the async block just calls that method
src/lib.rs
Outdated
}); | ||
// Backward compatibility function for error messages | ||
#[no_mangle] | ||
pub extern "C" fn iceberg_error_message() -> *const c_char { |
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.
remove this
No description provided.