This is an automated email from the ASF dual-hosted git repository.
xinyu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 99aa83d Merge pull request #14857 from [BEAM-9487] Add trigger safety
check to GroupByKey
add 85b85a5 [BEAM-12370] Support side input in Samza portable runner
(#14883)
No new revisions were added by this update.
Summary of changes:
.../streaming/ExecutableStageDoFnOperator.java | 4 +-
.../StreamingSideInputHandlerFactory.java} | 14 +--
runners/samza/build.gradle | 1 +
runners/samza/job-server/build.gradle | 3 +-
.../apache/beam/runners/samza/runtime/DoFnOp.java | 16 ++-
.../runners/samza/runtime/SamzaDoFnRunners.java | 17 ++-
.../samza/runtime/SamzaStateRequestHandlers.java | 69 +++++++++++
.../samza/translation/GroupByKeyTranslator.java | 65 +++++-----
.../translation/ParDoBoundMultiTranslator.java | 132 +++++++++++++++++++--
.../translation/PortableTranslationContext.java | 13 +-
.../translation/SamzaPublishViewTranslator.java | 39 +++---
.../samza/util/SamzaPipelineTranslatorUtils.java | 36 ------
12 files changed, 289 insertions(+), 120 deletions(-)
rename
runners/{flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkStreamingSideInputHandlerFactory.java
=>
java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/translation/StreamingSideInputHandlerFactory.java}
(93%)
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStateRequestHandlers.java
