This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 66b090d209efe5e7883450dff4e121147ba6fed9
Merge: 999bc5a c9fb261
Author: Ismaël Mejía <ieme...@gmail.com>
AuthorDate: Thu Jun 13 17:23:55 2019 +0200
Merge pull request #8841: [BEAM-7221] Spark portable runner: support timers
.../functions/FlinkExecutableStageFunction.java | 117 +------------------
.../fnexecution/control/TimerReceiverFactory.java | 90 ++++++++++++++
.../translation/PipelineTranslatorUtils.java | 58 +++++++++
runners/spark/job-server/build.gradle | 2 -
.../SparkBatchPortablePipelineTranslator.java | 16 +--
.../translation/SparkExecutableStageFunction.java | 130 ++++++++++++++++++---
.../SparkExecutableStageFunctionTest.java | 3 +-
.../runners/portability/spark_runner_test.py | 12 --
8 files changed, 276 insertions(+), 152 deletions(-)
