You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/05/09 14:52:32 UTC
[2/2] incubator-beam git commit: This closes #217
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 <kl...@google.com>
Authored: Mon May 9 07:52:15 2016 -0700
Committer: Kenneth Knowles <kl...@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(-)
----------------------------------------------------------------------