beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [4/4] beam git commit: This closes #3615: [BEAM-2656] Introduces AvroIO.readAll()
Date Wed, 26 Jul 2017 00:51:53 GMT
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 <kirpichov@google.com>
Authored: Tue Jul 25 17:37:06 2017 -0700
Committer: Eugene Kirpichov <kirpichov@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(-)
----------------------------------------------------------------------



Mime
View raw message