-
Notifications
You must be signed in to change notification settings - Fork 4k
ARROW-12043: [Rust] [Parquet] Write FSB arrays #9771
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
Conversation
jorgecarleitao
left a comment
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.
LGTM. Great addition, thanks a lot @nevi-me !
| ArrowDataType::FixedSizeBinary(_) => { | ||
| let mut col_writer = get_col_writer(&mut row_group_writer)?; | ||
| write_leaf( | ||
| &mut col_writer, | ||
| array, | ||
| levels.pop().expect("Levels exhausted"), | ||
| )?; | ||
| row_group_writer.close_column(col_writer)?; | ||
| Ok(()) | ||
| } |
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 can't spot the difference between this and all cases above. Is there any?
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.
lol, there isn't. Someone (won't name them) copied this chunk separately, thinking that it'll be different. Then they forgot to merge it when they realised that there was no difference.
I'll fix it shortly
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've fixed this
alamb
left a comment
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 good to me -- thanks @nevi-me
| "Attempting to write an Arrow type that is not yet implemented" | ||
| .to_string(), |
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.
| "Attempting to write an Arrow type that is not yet implemented" | |
| .to_string(), | |
| format!("Attempting to write an Arrow type {?} to parquet that is not yet implemented", array.data_type()) |
( I realize the error message is not changed by this PR I just saw it when looking)
1e91b45 to
5bf4197
Compare
Codecov Report
@@ Coverage Diff @@
## master #9771 +/- ##
==========================================
- Coverage 82.59% 82.41% -0.18%
==========================================
Files 248 252 +4
Lines 58294 58977 +683
==========================================
+ Hits 48149 48608 +459
- Misses 10145 10369 +224
Continue to review full report at Codecov.
|
Minor change to compute the levels for FSB arrays and write them out. Added a roundtrip test.