This closes #3282: [BEAM-3271] Improve Splittable ParDo translation Improve Splittable ParDo translation Fix RawPTransform translation
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/513c952f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/513c952f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/513c952f Branch: refs/heads/DSL_SQL Commit: 513c952fa65dbddee167160f6efabb634133425d Parents: 7c608c3 1b00d95 Author: Kenneth Knowles <[email protected]> Authored: Tue Jun 6 13:13:40 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue Jun 6 13:13:40 2017 -0700 ---------------------------------------------------------------------- .../construction/PTransformTranslation.java | 57 ++++++++++++++++---- .../core/construction/ParDoTranslation.java | 20 +++++++ .../core/construction/SplittableParDo.java | 18 +++++-- .../core/construction/ParDoTranslationTest.java | 35 +++++++++++- .../core/SplittableParDoViaKeyedWorkItems.java | 10 +++- runners/direct-java/pom.xml | 5 -- .../beam/runners/direct/DirectGroupByKey.java | 5 +- .../direct/KeyedPValueTrackingVisitor.java | 2 +- .../direct/ParDoMultiOverrideFactory.java | 3 +- .../direct/TestStreamEvaluatorFactory.java | 3 +- .../direct/TransformEvaluatorRegistry.java | 8 +-- .../runners/direct/ViewOverrideFactory.java | 3 +- .../src/main/proto/beam_runner_api.proto | 3 ++ 13 files changed, 138 insertions(+), 34 deletions(-) ----------------------------------------------------------------------
