This closes #2778
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/034565c6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/034565c6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/034565c6 Branch: refs/heads/master Commit: 034565c6811833fa1143362fb44f94672cef1e30 Parents: 6d443bc caf2fae Author: Eugene Kirpichov <kirpic...@google.com> Authored: Mon May 1 18:43:45 2017 -0700 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Mon May 1 18:43:45 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/spark/io/AvroPipelineTest.java | 4 +- .../java/org/apache/beam/sdk/io/AvroIO.java | 1193 +++++------------- .../java/org/apache/beam/sdk/io/AvroSink.java | 142 +++ .../java/org/apache/beam/sdk/io/AvroSource.java | 4 +- .../java/org/apache/beam/sdk/io/TextIO.java | 4 +- .../beam/sdk/testing/SourceTestUtils.java | 5 +- .../java/org/apache/beam/sdk/io/AvroIOTest.java | 108 +- .../apache/beam/sdk/io/AvroIOTransformTest.java | 30 +- 8 files changed, 521 insertions(+), 969 deletions(-) ----------------------------------------------------------------------
