This closes #2724
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0c740f43 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0c740f43 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0c740f43 Branch: refs/heads/master Commit: 0c740f436a081197a3917c30d4f7db2234976845 Parents: 1babed2 235a79a Author: Dan Halperin <[email protected]> Authored: Thu Apr 27 10:24:51 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Thu Apr 27 10:24:51 2017 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/FileBasedSink.java | 46 +++++++++++++++++- .../apache/beam/sdk/util/IOChannelUtils.java | 50 ++------------------ .../java/org/apache/beam/sdk/io/AvroIOTest.java | 2 +- .../apache/beam/sdk/io/FileBasedSinkTest.java | 27 ++++++++++- .../java/org/apache/beam/sdk/io/TextIOTest.java | 2 +- .../beam/sdk/util/IOChannelUtilsTest.java | 30 ------------ 6 files changed, 75 insertions(+), 82 deletions(-) ----------------------------------------------------------------------
