-
Notifications
You must be signed in to change notification settings - Fork 4.5k
[BEAM-10523] Add support for custom DatumWriters to AvroIO.Write #12299
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
3d55656 to
a8b5331
Compare
|
ping? |
|
@iemejia @RyanSkraba can one of you take a look at this, or recommend someone who can? |
RyanSkraba
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, and consistent! Thanks for the contribution.
sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java
Outdated
Show resolved
Hide resolved
|
Please rebase and it should be good to go. I felt a bit uneasy about making |
561cae9 to
6fe2d2e
Compare
6fe2d2e to
6bed6de
Compare
|
rebased, I think I got all the (lol there's an @ Nullable github account, oops) |
|
Run Spotless PreCommit |
|
rebased, ptal @iemejia @RyanSkraba |
iemejia
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
|
Thanks @steveniemitz now the feature looks complete 👍 |
Similar to #11641 and #11479, this change allows configuring the IO to use custom DatumWriter implementations.
R: @iemejia @RyanSkraba
Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:
R: @username).[BEAM-XXX] Fixes bug in ApproximateQuantiles, where you replaceBEAM-XXXwith the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.CHANGES.mdwith noteworthy changes.See the Contributor Guide for more tips on how to make review process smoother.
Post-Commit Tests Status (on master branch)
Pre-Commit Tests Status (on master branch)
See .test-infra/jenkins/README for trigger phrase, status and link of all Jenkins jobs.