This closes #3615: [BEAM-2656] Introduces AvroIO.readAll()
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d919394c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d919394c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d919394c Branch: refs/heads/master Commit: d919394c7fb4080a2069d24da5a09a410e215e9f Parents: 71196ec ee1bcba Author: Eugene Kirpichov <[email protected]> Authored: Tue Jul 25 17:37:06 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Tue Jul 25 17:37:06 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/AvroIO.java | 165 +++++++++++++++---- .../java/org/apache/beam/sdk/io/AvroSource.java | 24 ++- .../java/org/apache/beam/sdk/io/AvroUtils.java | 40 +++++ .../apache/beam/sdk/io/BlockBasedSource.java | 6 + .../beam/sdk/io/ReadAllViaFileBasedSource.java | 152 +++++++++++++++++ .../java/org/apache/beam/sdk/io/TextIO.java | 135 +++------------ .../java/org/apache/beam/sdk/io/AvroIOTest.java | 65 +++++++- 7 files changed, 436 insertions(+), 151 deletions(-) ----------------------------------------------------------------------
