This closes #2145
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bb8cd72b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bb8cd72b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bb8cd72b Branch: refs/heads/master Commit: bb8cd72b98b261c781add91191d246a650de2cd3 Parents: 7e9233b 6253aba Author: Thomas Groh <[email protected]> Authored: Fri Mar 3 15:36:10 2017 -0800 Committer: Thomas Groh <[email protected]> Committed: Fri Mar 3 15:36: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, 668 insertions(+), 1079 deletions(-) ----------------------------------------------------------------------
