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(-) ----------------------------------------------------------------------