This closes #1511
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5b31a369 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5b31a369 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5b31a369 Branch: refs/heads/master Commit: 5b31a369962907e257de8019fbf6cde4c615b1c0 Parents: ae52ec1 55d333b Author: Thomas Groh <tg...@google.com> Authored: Wed Dec 7 09:14:38 2016 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Wed Dec 7 09:14:38 2016 -0800 ---------------------------------------------------------------------- .../apex/translation/TranslationContext.java | 4 +-- .../beam/runners/direct/DirectGraphVisitor.java | 9 +++---- .../direct/KeyedPValueTrackingVisitor.java | 2 +- .../FlinkBatchPipelineTranslator.java | 4 +-- .../FlinkStreamingPipelineTranslator.java | 7 ++---- .../dataflow/DataflowPipelineTranslator.java | 3 +-- .../apache/beam/runners/spark/SparkRunner.java | 17 +++++++------ .../beam/sdk/runners/TransformHierarchy.java | 26 +++++++++++--------- .../sdk/runners/TransformHierarchyTest.java | 13 ++++------ 9 files changed, 38 insertions(+), 47 deletions(-) ----------------------------------------------------------------------