You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/07/19 00:08:00 UTC
[3/4] incubator-beam git commit: Closes #651
Closes #651
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/69e22023
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/69e22023
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/69e22023
Branch: refs/heads/master
Commit: 69e22023f7efe3a216776297293e9d9c34d8e534
Parents: 52331d9 1535d73
Author: Dan Halperin <dh...@google.com>
Authored: Mon Jul 18 17:07:41 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Jul 18 17:07:41 2016 -0700
----------------------------------------------------------------------
.../beam/runners/direct/DirectRunner.java | 2 +
.../direct/WriteWithShardingFactory.java | 141 +++++++++
.../direct/WriteWithShardingFactoryTest.java | 285 +++++++++++++++++++
.../translation/TransformTranslatorTest.java | 32 ++-
.../beam/sdk/util/FileIOChannelFactory.java | 3 +-
.../java/org/apache/beam/sdk/io/TextIOTest.java | 24 +-
.../java/org/apache/beam/sdk/io/WriteTest.java | 4 +-
7 files changed, 473 insertions(+), 18 deletions(-)
----------------------------------------------------------------------