You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/04/20 22:10:25 UTC
[3/3] beam git commit: This closes #2563
This closes #2563
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e4491888
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e4491888
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e4491888
Branch: refs/heads/master
Commit: e44918881794ef80c83a6a119ec52861bece28a9
Parents: 4f8b1cc 49b8b23
Author: Dan Halperin <dh...@google.com>
Authored: Thu Apr 20 15:10:14 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu Apr 20 15:10:14 2017 -0700
----------------------------------------------------------------------
.../UnboundedReadFromBoundedSource.java | 3 +-
.../UnboundedReadFromBoundedSourceTest.java | 14 +-
.../translation/wrappers/SourceInputFormat.java | 3 +-
.../beam/runners/spark/io/MicrobatchSource.java | 4 +-
.../java/org/apache/beam/sdk/io/AvroSource.java | 43 +--
.../apache/beam/sdk/io/BlockBasedSource.java | 10 +-
.../apache/beam/sdk/io/CompressedSource.java | 26 +-
.../org/apache/beam/sdk/io/FileBasedSource.java | 355 +++++++------------
.../org/apache/beam/sdk/io/FileSystems.java | 32 +-
.../org/apache/beam/sdk/io/LocalResourceId.java | 29 +-
.../java/org/apache/beam/sdk/io/TFRecordIO.java | 17 +-
.../java/org/apache/beam/sdk/io/TextIO.java | 21 +-
.../java/org/apache/beam/sdk/io/XmlSource.java | 12 +-
.../org/apache/beam/sdk/io/fs/MatchResult.java | 3 +-
.../org/apache/beam/sdk/io/fs/ResourceId.java | 3 +-
.../org/apache/beam/sdk/util/AvroUtils.java | 24 +-
.../org/apache/beam/sdk/io/AvroSourceTest.java | 15 +-
.../beam/sdk/io/CompressedSourceTest.java | 12 +-
.../apache/beam/sdk/io/FileBasedSourceTest.java | 192 +++-------
.../org/apache/beam/sdk/util/AvroUtilsTest.java | 9 +-
.../java/org/apache/beam/sdk/util/GcsUtil.java | 5 +-
.../org/apache/beam/sdk/util/gcsfs/GcsPath.java | 5 +-
.../sdk/io/gcp/bigtable/BigtableIOTest.java | 6 +-
.../inputformat/HadoopInputFormatIOTest.java | 2 +-
24 files changed, 349 insertions(+), 496 deletions(-)
----------------------------------------------------------------------