This closes #1469
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/48130f71 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/48130f71 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/48130f71 Branch: refs/heads/master Commit: 48130f718d019d6928c464e6f7ad90cd510b62d2 Parents: 0c875ba ab1f1ad Author: Thomas Groh <tg...@google.com> Authored: Thu Dec 1 12:55:26 2016 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Thu Dec 1 12:55:26 2016 -0800 ---------------------------------------------------------------------- .../direct/KeyedPValueTrackingVisitor.java | 2 +- .../DataflowPipelineTranslatorTest.java | 2 +- .../main/java/org/apache/beam/sdk/Pipeline.java | 117 +++--------- .../beam/sdk/runners/TransformHierarchy.java | 126 ++++++++----- .../beam/sdk/runners/TransformTreeNode.java | 165 +++++++++-------- .../sdk/runners/TransformHierarchyTest.java | 180 ++++++++++++++----- .../beam/sdk/runners/TransformTreeTest.java | 4 +- 7 files changed, 340 insertions(+), 256 deletions(-) ----------------------------------------------------------------------
