You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2016/12/07 17:15:07 UTC
[2/2] incubator-beam git commit: This closes #1511
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(-)
----------------------------------------------------------------------