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/08/24 16:44:31 UTC

[beam] branch master updated (2a6601b -> 7611831)

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 2a6601b  [Go SDK] Go SDK Exits Experimental (#15374)
     add 7611831  [BEAM-12724][BEAM-12349] Support user timers in Samza portable runner (#15349)

No new revisions were added by this update.

Summary of changes:
 runners/samza/job-server/build.gradle              |  2 -
 .../apache/beam/runners/samza/runtime/DoFnOp.java  | 22 +++---
 .../runtime/DoFnRunnerWithKeyedInternals.java      | 39 ++++------
 .../runners/samza/runtime/SamzaDoFnRunners.java    | 59 ++++++++++++++-
 .../samza/translation/GroupByKeyTranslator.java    |  5 +-
 .../translation/ParDoBoundMultiTranslator.java     |  7 +-
 .../translation/PortableTranslationContext.java    | 53 +------------
 .../beam/runners/samza/util/WindowUtils.java       | 74 ++++++++++++++++++
 .../beam/runners/samza/util/WindowUtilsTest.java   | 87 ++++++++++++++++++++++
 .../runners/portability/samza_runner_test.py       | 24 +-----
 10 files changed, 255 insertions(+), 117 deletions(-)
 create mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/WindowUtils.java
 create mode 100644 runners/samza/src/test/java/org/apache/beam/runners/samza/util/WindowUtilsTest.java