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/04/22 03:21:31 UTC

[3/3] incubator-beam git commit: Closes #183

Closes #183


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a5548f91
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a5548f91
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a5548f91

Branch: refs/heads/master
Commit: a5548f915df1449ab4e2d7841ef6d696ae28cd5c
Parents: 640e258 59fd4b3
Author: Dan Halperin <dh...@google.com>
Authored: Thu Apr 21 18:20:55 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu Apr 21 18:20:55 2016 -0700

----------------------------------------------------------------------
 .../sdk/runners/DataflowPipelineTranslator.java |  42 ----
 .../sdk/runners/DataflowPipelineRunnerTest.java |  12 +-
 .../runners/DataflowPipelineTranslatorTest.java |   4 +-
 .../sdk/runners/inprocess/InProcessCreate.java  | 236 -------------------
 .../inprocess/InProcessPipelineRunner.java      |   3 -
 .../org/apache/beam/sdk/transforms/Create.java  | 198 ++++++++++++----
 .../beam/sdk/runners/TransformTreeTest.java     |   3 +-
 .../EncodabilityEnforcementFactoryTest.java     |  43 ++--
 .../runners/inprocess/InProcessCreateTest.java  | 236 -------------------
 .../apache/beam/sdk/transforms/CreateTest.java  | 134 +++++++++++
 10 files changed, 315 insertions(+), 596 deletions(-)
----------------------------------------------------------------------