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/06/29 00:10:15 UTC

[2/2] incubator-beam git commit: Closes #534

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 <dh...@google.com>
Authored: Tue Jun 28 17:09:48 2016 -0700
Committer: Dan Halperin <dh...@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(-)
----------------------------------------------------------------------