You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ie...@apache.org on 2020/08/18 20:21:17 UTC

[beam] 01/01: Merge pull request #12299: [BEAM-10523] Add support for custom DatumWriters to AvroIO.Write

This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 154a3832b9e4d1e3e74bbd29666dbfa89dd9d434
Merge: ab12f12 6bed6de
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Tue Aug 18 22:20:53 2020 +0200

    Merge pull request #12299: [BEAM-10523] Add support for custom DatumWriters to AvroIO.Write

 .../main/java/org/apache/beam/sdk/io/AvroIO.java   | 39 +++++++++++-
 .../main/java/org/apache/beam/sdk/io/AvroSink.java | 27 ++++++--
 .../beam/sdk/io/ConstantAvroDestination.java       | 17 +++++
 .../beam/sdk/io/DynamicAvroDestinations.java       | 14 ++++-
 .../java/org/apache/beam/sdk/io/AvroIOTest.java    | 72 ++++++++++++++++++++++
 5 files changed, 159 insertions(+), 10 deletions(-)