This closes #217
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/03e99540 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/03e99540 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/03e99540 Branch: refs/heads/master Commit: 03e99540abfa545c7aece1f89c04578c8e59950e Parents: 07c60a9 dbf7a06 Author: Kenneth Knowles <k...@google.com> Authored: Mon May 9 07:52:15 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Mon May 9 07:52:15 2016 -0700 ---------------------------------------------------------------------- .../direct/ConsumerTrackingPipelineVisitor.java | 7 +- .../direct/KeyedPValueTrackingVisitor.java | 5 +- .../FlinkBatchPipelineTranslator.java | 83 +++++++++----------- .../translation/FlinkPipelineTranslator.java | 2 +- .../FlinkStreamingPipelineTranslator.java | 35 ++------- .../dataflow/DataflowPipelineRunner.java | 5 +- .../dataflow/DataflowPipelineTranslator.java | 7 +- .../dataflow/DataflowPipelineRunnerTest.java | 18 +---- .../beam/runners/spark/SparkPipelineRunner.java | 48 ++--------- .../main/java/org/apache/beam/sdk/Pipeline.java | 35 ++++++++- .../runners/AggregatorPipelineExtractor.java | 10 +-- .../beam/sdk/runners/DirectPipelineRunner.java | 12 +-- .../sdk/runners/RecordingPipelineVisitor.java | 12 +-- .../beam/sdk/runners/TransformTreeNode.java | 16 ++-- .../AggregatorPipelineExtractorTest.java | 2 +- .../beam/sdk/runners/TransformTreeTest.java | 12 +-- 16 files changed, 124 insertions(+), 185 deletions(-) ----------------------------------------------------------------------