You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by da...@apache.org on 2016/12/10 19:12:49 UTC

[2/2] incubator-beam git commit: This closes #1545

This closes #1545


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e841b1a2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e841b1a2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e841b1a2

Branch: refs/heads/master
Commit: e841b1a21d850947a8cda9d897f2f51cac5ee2f1
Parents: a834fb0 9ebc465
Author: Davor Bonaci <da...@google.com>
Authored: Sat Dec 10 11:12:36 2016 -0800
Committer: Davor Bonaci <da...@google.com>
Committed: Sat Dec 10 11:12:36 2016 -0800

----------------------------------------------------------------------
 .../beam/runners/dataflow/DataflowRunner.java   |  7 ++-
 .../runners/dataflow/DataflowRunnerTest.java    | 20 +++++++
 .../org/apache/beam/sdk/io/FileBasedSink.java   | 62 ++++++++++++--------
 .../apache/beam/sdk/io/FileBasedSinkTest.java   |  6 +-
 .../java/org/apache/beam/sdk/io/TextIOTest.java | 19 ++++++
 .../org/apache/beam/sdk/io/XmlSinkTest.java     |  4 +-
 6 files changed, 89 insertions(+), 29 deletions(-)
----------------------------------------------------------------------