beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [5/5] beam git commit: This finishes #3799: [BEAM-2828, BEAM-2750] Introduces FileIO.read() and uses it in Text, Avro and Xml
Date Sun, 03 Sep 2017 23:49:21 GMT
This finishes #3799: [BEAM-2828, BEAM-2750] Introduces FileIO.read() and uses it in Text, Avro
and Xml


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c3bcd4b4
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c3bcd4b4
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c3bcd4b4

Branch: refs/heads/master
Commit: c3bcd4b425ecaecdc5a0d5ffa272cf8727da29f7
Parents: 80b9cf9 abda38d
Author: Eugene Kirpichov <ekirpichov@gmail.com>
Authored: Sun Sep 3 16:34:16 2017 -0700
Committer: Eugene Kirpichov <ekirpichov@gmail.com>
Committed: Sun Sep 3 16:34:16 2017 -0700

----------------------------------------------------------------------
 .../apache/beam/sdk/coders/CoderRegistry.java   |   6 +
 .../java/org/apache/beam/sdk/io/AvroIO.java     |  14 +-
 .../java/org/apache/beam/sdk/io/FileIO.java     | 187 ++++++++++-
 .../beam/sdk/io/ReadAllViaFileBasedSource.java  |  73 +++--
 .../apache/beam/sdk/io/ReadableFileCoder.java   |  50 +++
 .../java/org/apache/beam/sdk/io/TextIO.java     |  95 +++---
 .../java/org/apache/beam/sdk/io/FileIOTest.java | 313 +++++++++++++++++++
 .../org/apache/beam/sdk/io/TextIOReadTest.java  |  25 +-
 .../java/org/apache/beam/sdk/io/xml/XmlIO.java  | 280 +++++++++++------
 .../org/apache/beam/sdk/io/xml/XmlSource.java   |  63 ++--
 .../apache/beam/sdk/io/xml/XmlSourceTest.java   |  74 +----
 11 files changed, 911 insertions(+), 269 deletions(-)
----------------------------------------------------------------------



Mime
View raw message