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

Posted to commits@beam.apache.org by mx...@apache.org on 2018/10/25 16:07:09 UTC

[beam] 01/01: Merge pull request #6740: [BEAM-2918] Add state support for batch in portable FlinkRunner

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

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

commit d19cf3fd66a575a95403aaf21e191157d34953c7
Merge: 5a24fc9 d448a96
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Thu Oct 25 18:06:59 2018 +0200

    Merge pull request #6740: [BEAM-2918] Add state support for batch in portable FlinkRunner

 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   3 +-
 .../FlinkBatchPortablePipelineTranslator.java      |  48 ++++--
 .../flink/FlinkBatchTransformTranslators.java      |   2 +-
 .../FlinkStreamingPortablePipelineTranslator.java  |  14 +-
 .../FlinkBatchSideInputHandlerFactory.java         |   2 +-
 .../functions/FlinkExecutableStageFunction.java    | 171 +++++++++++++++++++--
 .../utils/FlinkPipelineTranslatorUtils.java        |  18 +++
 .../runners/flink/PortableStateExecutionTest.java  |  28 +++-
 .../FlinkExecutableStageFunctionTest.java          |  22 ++-
 .../beam/fn/harness/state/FnApiStateAccessor.java  |  13 +-
 .../runners/portability/flink_runner_test.py       |   6 -
 11 files changed, 276 insertions(+), 51 deletions(-)