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

Posted to commits@beam.apache.org by xi...@apache.org on 2021/05/27 22:47:45 UTC

[beam] branch master updated (99aa83d -> 85b85a5)

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