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

Posted to commits@beam.apache.org by dm...@apache.org on 2020/06/01 07:46:34 UTC

[beam] 01/01: Merge pull request #11858: [BEAM-8608] Chain DoFns in Flink batch runner when possible.

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

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

commit 1a8c56380c924e25135a13dfdc0a5cb101cfddf1
Merge: 1bd1508 3689296
Author: David Moravek <dm...@apache.org>
AuthorDate: Mon Jun 1 09:46:07 2020 +0200

    Merge pull request #11858: [BEAM-8608] Chain DoFns in Flink batch runner when possible.
    
    [BEAM-8608] Chain DoFns in Flink batch runner when possible.

 .../beam/runners/flink/FlinkCapabilities.java      |  34 +++++
 .../beam/runners/flink/FlinkCapabilities.java      |  34 +++++
 .../flink/FlinkBatchTransformTranslators.java      |  21 ++-
 .../translation/functions/FlinkDoFnFunction.java   | 156 ++++++++++++++-------
 .../functions/FlinkStatefulDoFnFunction.java       |   7 +-
 .../src/main/resources/beam/suppressions.xml       |   1 +
 6 files changed, 194 insertions(+), 59 deletions(-)