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 2017/03/06 17:09:23 UTC
[3/3] beam git commit: This closes #2170
This closes #2170
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9cc8018b
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9cc8018b
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9cc8018b
Branch: refs/heads/master
Commit: 9cc8018b3ed945244bb311134ebd824016d1633f
Parents: 34b38ef 8766b03
Author: Thomas Groh <tg...@google.com>
Authored: Mon Mar 6 09:09:10 2017 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Mon Mar 6 09:09:10 2017 -0800
----------------------------------------------------------------------
.../translation/ApexPipelineTranslator.java | 3 +-
.../translation/ParDoBoundMultiTranslator.java | 185 ++++++++++
.../apex/translation/ParDoBoundTranslator.java | 95 +++++
.../apex/translation/ParDoTranslator.java | 185 ----------
.../FlattenPCollectionTranslatorTest.java | 3 +-
.../translation/ParDoBoundTranslatorTest.java | 344 +++++++++++++++++++
.../apex/translation/ParDoTranslatorTest.java | 344 -------------------
.../beam/runners/direct/DirectRunner.java | 18 +-
.../ParDoSingleViaMultiOverrideFactory.java | 70 ++++
.../ParDoSingleViaMultiOverrideFactoryTest.java | 46 +++
.../flink/FlinkBatchTransformTranslators.java | 78 ++++-
.../FlinkStreamingTransformTranslators.java | 113 +++++-
.../dataflow/DataflowPipelineTranslator.java | 29 ++
.../DataflowPipelineTranslatorTest.java | 7 +-
.../spark/translation/TransformTranslator.java | 100 +++---
.../streaming/StreamingTransformTranslator.java | 115 +++----
.../streaming/TrackStreamingSourcesTest.java | 4 +-
.../org/apache/beam/sdk/transforms/ParDo.java | 8 +-
18 files changed, 1079 insertions(+), 668 deletions(-)
----------------------------------------------------------------------