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 <dhalp...@google.com> Authored: Thu Apr 20 15:10:14 2017 -0700 Committer: Dan Halperin <dhalp...@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(-) ----------------------------------------------------------------------