You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by th...@apache.org on 2016/11/07 19:59:05 UTC

[15/50] incubator-beam git commit: Closes #1050

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/apex-runner
Commit: 55d951987e79b6c9c97d14ea72d60293a3537b9d
Parents: c6c41ea 8c1008c
Author: Dan Halperin <dh...@google.com>
Authored: Thu Nov 3 12:39:13 2016 -0700
Committer: Dan Halperin <dh...@google.com>
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(-)
----------------------------------------------------------------------