You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/04/11 22:20:57 UTC
[2/2] incubator-beam git commit: [BEAM-22] This closes #148
[BEAM-22] This closes #148
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e1a47117
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e1a47117
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e1a47117
Branch: refs/heads/master
Commit: e1a471176ab6fdfb5b1d1cdbcdcf8ba7ab726d00
Parents: cd2a3a1 a8ce5fd
Author: Luke Cwik <lc...@google.com>
Authored: Mon Apr 11 13:20:43 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Mon Apr 11 13:20:43 2016 -0700
----------------------------------------------------------------------
.../inprocess/AvroIOShardedWriteFactory.java | 76 +++++++++++++
.../inprocess/InProcessPipelineRunner.java | 4 +
.../runners/inprocess/ShardControlledWrite.java | 81 ++++++++++++++
.../inprocess/TextIOShardedWriteFactory.java | 78 +++++++++++++
.../cloud/dataflow/sdk/io/AvroIOTest.java | 30 ++---
.../cloud/dataflow/sdk/io/TextIOTest.java | 33 +++---
.../AvroIOShardedWriteFactoryTest.java | 112 +++++++++++++++++++
.../TextIOShardedWriteFactoryTest.java | 112 +++++++++++++++++++
8 files changed, 498 insertions(+), 28 deletions(-)
----------------------------------------------------------------------