Closes #1038
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/142229e3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/142229e3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/142229e3 Branch: refs/heads/master Commit: 142229e3719952451ef9a65c4cfc77c2d27520fd Parents: 4f991fd 2b22d00 Author: Dan Halperin <dhalp...@google.com> Authored: Wed Oct 12 09:35:49 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Wed Oct 12 09:35:49 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/AvroIO.java | 158 ++++++++++++++++--- .../sdk/io/SerializableAvroCodecFactory.java | 112 +++++++++++++ .../java/org/apache/beam/sdk/io/AvroIOTest.java | 107 ++++++++++++- .../io/SerializableAvroCodecFactoryTest.java | 100 ++++++++++++ 4 files changed, 458 insertions(+), 19 deletions(-) ----------------------------------------------------------------------
