Closes #534
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/daafc86f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/daafc86f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/daafc86f Branch: refs/heads/master Commit: daafc86f3827db289589087e550ed9827e6f8f4b Parents: d5d3035 0070d2d Author: Dan Halperin <dhalp...@google.com> Authored: Tue Jun 28 17:09:48 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Tue Jun 28 17:09:48 2016 -0700 ---------------------------------------------------------------------- .../direct/AvroIOShardedWriteFactory.java | 76 ----- .../beam/runners/direct/DirectRunner.java | 4 - .../runners/direct/ShardControlledWrite.java | 81 ----- .../direct/TextIOShardedWriteFactory.java | 78 ----- .../direct/AvroIOShardedWriteFactoryTest.java | 120 ------- .../direct/TextIOShardedWriteFactoryTest.java | 120 ------- .../beam/runners/dataflow/DataflowRunner.java | 258 --------------- .../java/org/apache/beam/sdk/io/AvroIO.java | 12 +- .../java/org/apache/beam/sdk/io/TextIO.java | 15 +- .../main/java/org/apache/beam/sdk/io/Write.java | 314 ++++++++++++++----- .../java/org/apache/beam/sdk/io/WriteTest.java | 145 ++++++++- 11 files changed, 391 insertions(+), 832 deletions(-) ----------------------------------------------------------------------
