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/11/19 16:04:27 UTC
[beam] 01/01: Merge pull request #7008: [BEAM-4681] Add support for
portable timers in Flink batch mode
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 50f623c023f423aab1336aee136c36ef3c82d1ca
Merge: e4bb78a b752ad5
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Mon Nov 19 17:04:19 2018 +0100
Merge pull request #7008: [BEAM-4681] Add support for portable timers in Flink batch mode
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 -
.../FlinkBatchPortablePipelineTranslator.java | 19 +-
.../functions/FlinkExecutableStageFunction.java | 254 ++++++++++++++++++---
.../wrappers/streaming/DoFnOperator.java | 68 +++++-
.../streaming/ExecutableStageDoFnOperator.java | 49 ++--
.../runners/flink/PortableTimersExecutionTest.java | 3 +-
.../runners/flink/streaming/DoFnOperatorTest.java | 13 +-
.../FlinkExecutableStageFunctionTest.java | 48 ++--
.../runners/portability/flink_runner_test.py | 4 -
9 files changed, 349 insertions(+), 111 deletions(-)