You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/07/26 00:51:53 UTC
[4/4] beam git commit: This closes #3615: [BEAM-2656] Introduces
AvroIO.readAll()
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 <ki...@google.com>
Authored: Tue Jul 25 17:37:06 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
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(-)
----------------------------------------------------------------------