Closes #1050
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/55d95198 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/55d95198 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/55d95198 Branch: refs/heads/master Commit: 55d951987e79b6c9c97d14ea72d60293a3537b9d Parents: c6c41ea 8c1008c Author: Dan Halperin <[email protected]> Authored: Thu Nov 3 12:39:13 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Thu Nov 3 12:39:13 2016 -0700 ---------------------------------------------------------------------- .../examples/MinimalWordCountJava8Test.java | 2 +- .../org/apache/beam/sdk/io/FileBasedSink.java | 34 +++++++++++++++----- .../beam/sdk/util/FileIOChannelFactory.java | 8 +++-- .../beam/sdk/util/GcsIOChannelFactory.java | 8 ++++- .../apache/beam/sdk/util/IOChannelFactory.java | 4 +++ .../org/apache/beam/sdk/util/gcsfs/GcsPath.java | 13 ++++++-- .../apache/beam/sdk/io/FileBasedSinkTest.java | 23 +++++++------ .../org/apache/beam/sdk/io/XmlSinkTest.java | 16 +++++++-- .../apache/beam/sdk/util/gcsfs/GcsPathTest.java | 25 ++++++++++++++ 9 files changed, 107 insertions(+), 26 deletions(-) ----------------------------------------------------------------------
