You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ro...@apache.org on 2018/12/11 14:28:35 UTC

[beam] 01/01: Merge pull request #7228 from [BEAM-4678] Combiner lifting in portable Flink.

This is an automated email from the ASF dual-hosted git repository.

robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit d4237ec45d2fca22af9de165a44e03c93040ca92
Merge: edc37f9 3398a88
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Tue Dec 11 15:28:27 2018 +0100

    Merge pull request #7228 from [BEAM-4678] Combiner lifting in portable Flink.
    
    [BEAM-4678] Support combiner lifting in portable Flink runner.

 .../pipeline/src/main/proto/beam_runner_api.proto  |   1 +
 .../runners/core/construction/Environments.java    |   9 ++
 .../core/construction/PTransformTranslation.java   |   6 +
 .../graph/GreedyPCollectionFusers.java             |  28 +++-
 .../core/construction/graph/QueryablePipeline.java |   6 +
 .../runners/portability/fn_api_runner.py           | 137 ++---------------
 .../portability/fn_api_runner_transforms.py        | 162 +++++++++++++++++++++
 .../runners/portability/portable_runner.py         |  13 ++
 8 files changed, 229 insertions(+), 133 deletions(-)