Repository: beam Updated Branches: refs/heads/master 154c54305 -> 2982238f7
This closes #2058 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2982238f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2982238f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2982238f Branch: refs/heads/master Commit: 2982238f7ae2aceb49f4acfa1ef2cf3ab9d21486 Parents: 154c543 b6863b1 Author: Thomas Groh <tg...@google.com> Authored: Tue Feb 21 15:21:41 2017 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Tue Feb 21 15:21:41 2017 -0800 ---------------------------------------------------------------------- .../dataflow/DataflowPipelineTranslator.java | 97 ++++++++++---------- .../beam/runners/dataflow/DataflowRunner.java | 3 +- .../runners/dataflow/TransformTranslator.java | 13 ++- .../DataflowPipelineTranslatorTest.java | 7 +- .../java/org/apache/beam/sdk/values/PValue.java | 9 -- 5 files changed, 67 insertions(+), 62 deletions(-) ----------------------------------------------------------------------
