This closes #2056
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0b7515e5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0b7515e5 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0b7515e5 Branch: refs/heads/master Commit: 0b7515e5e56c56e89aa75889ec4c08fba9645b8e Parents: aaf0884 63035de Author: Dan Halperin <[email protected]> Authored: Mon Feb 27 09:37:58 2017 -0800 Committer: Dan Halperin <[email protected]> Committed: Mon Feb 27 09:37:58 2017 -0800 ---------------------------------------------------------------------- .../apache/beam/sdk/io/CompressedSource.java | 32 +++++++-- .../org/apache/beam/sdk/io/FileBasedSink.java | 11 +++ .../java/org/apache/beam/sdk/io/TextIO.java | 10 ++- .../beam/sdk/io/CompressedSourceTest.java | 72 ++++++++++++++++++++ .../apache/beam/sdk/io/FileBasedSinkTest.java | 17 ++++- .../java/org/apache/beam/sdk/io/TextIOTest.java | 29 ++++++++ 6 files changed, 162 insertions(+), 9 deletions(-) ----------------------------------------------------------------------
