Repository: beam Updated Branches: refs/heads/master 9335738f0 -> 918c7fa36
This closes #1941 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/918c7fa3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/918c7fa3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/918c7fa3 Branch: refs/heads/master Commit: 918c7fa3666e60343b86087c3450e77291b4d024 Parents: 9335738 0b73749 Author: Thomas Groh <tg...@google.com> Authored: Fri Feb 17 16:27:23 2017 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Fri Feb 17 16:27:23 2017 -0800 ---------------------------------------------------------------------- .../direct/WriteWithShardingFactory.java | 2 +- .../main/java/org/apache/beam/sdk/io/Write.java | 195 +++++++++++++++---- .../java/org/apache/beam/sdk/io/WriteTest.java | 138 +++++++++++-- 3 files changed, 281 insertions(+), 54 deletions(-) ----------------------------------------------------------------------
