Skip to content
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

[Rust] Minimal dataset append support #482

Merged
merged 3 commits into from
Jan 29, 2023
Merged

[Rust] Minimal dataset append support #482

merged 3 commits into from
Jan 29, 2023

Conversation

eddyxu
Copy link
Contributor

@eddyxu eddyxu commented Jan 28, 2023

Bring back Append support in schema evolution

@eddyxu eddyxu requested a review from changhiskhan January 28, 2023 23:51
@eddyxu eddyxu self-assigned this Jan 29, 2023
Copy link
Contributor

@changhiskhan changhiskhan left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Curious if it makes sense to make a DatasetWriter yet?

@@ -175,7 +175,7 @@ mod tests {
let mut params = WriteParams::default();
params.max_rows_per_group = 10;
let mut reader: Box<dyn RecordBatchReader> = Box::new(batches);
Dataset::create(&mut reader, path, Some(params))
Dataset::write(&mut reader, path, Some(params))
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think pyo3 will break on the name change. Don't have GHA yet for this so it's annoying. I will try to add it tonight

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Oh, that's nice. Thanks.

}
}

let mut fragment_id = latest_manifest.as_ref().map_or(0, |m| {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

would it make sense to put max fragment in manifest?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is interesting about how to enforce it. i.e., allow a background thread to start compact but allow writing, or just hard stop users to append new fragments.

This could be a question we need to answer when the scale is up.

@eddyxu
Copy link
Contributor Author

eddyxu commented Jan 29, 2023

Curious if it makes sense to make a DatasetWriter yet?

Is this the same concept as Updater in C++ codebase, or something new?

@eddyxu eddyxu merged commit 822ed87 into main Jan 29, 2023
@eddyxu eddyxu deleted the lei/append branch January 29, 2023 02:05
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants