You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2017/06/08 01:35:06 UTC
[17/50] beam git commit: This closes #3282: [BEAM-3271] Improve
Splittable ParDo translation
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 <kl...@google.com>
Authored: Tue Jun 6 13:13:40 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
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(-)
----------------------------------------------------------------------