This closes #1484
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/63491bf2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/63491bf2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/63491bf2 Branch: refs/heads/gearpump-runner Commit: 63491bf211d8b2f23f6b7db1375a733c4332b850 Parents: 24fab9f 7c5c791 Author: Thomas Groh <tg...@google.com> Authored: Thu Dec 1 14:34:21 2016 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Thu Dec 1 14:34:21 2016 -0800 ---------------------------------------------------------------------- .../translation/ApexPipelineTranslator.java | 12 +- .../apex/translation/TranslationContext.java | 6 +- .../direct/ConsumerTrackingPipelineVisitor.java | 12 +- .../runners/direct/DisplayDataValidator.java | 6 +- .../direct/KeyedPValueTrackingVisitor.java | 10 +- .../apache/beam/runners/flink/FlinkRunner.java | 12 +- .../FlinkBatchPipelineTranslator.java | 14 +- .../FlinkStreamingPipelineTranslator.java | 16 +- .../PipelineTranslationOptimizer.java | 10 +- .../dataflow/DataflowPipelineTranslator.java | 8 +- .../beam/runners/dataflow/DataflowRunner.java | 10 +- .../runners/dataflow/DataflowRunnerTest.java | 4 +- .../dataflow/RecordingPipelineVisitor.java | 6 +- .../apache/beam/runners/spark/SparkRunner.java | 21 +- .../beam/sdk/AggregatorPipelineExtractor.java | 6 +- .../main/java/org/apache/beam/sdk/Pipeline.java | 17 +- .../beam/sdk/runners/TransformHierarchy.java | 244 +++++++++++++++- .../beam/sdk/runners/TransformTreeNode.java | 282 ------------------- .../sdk/AggregatorPipelineExtractorTest.java | 20 +- .../sdk/runners/TransformHierarchyTest.java | 26 +- .../beam/sdk/runners/TransformTreeTest.java | 8 +- .../display/DisplayDataEvaluator.java | 8 +- 22 files changed, 344 insertions(+), 414 deletions(-) ----------------------------------------------------------------------
