beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xi...@apache.org
Subject [beam] branch master updated (09548a9 -> b5820a2)
Date Tue, 10 Aug 2021 16:52:52 GMT
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 09548a9  Merge pull request #15302 from chamikaramj/fix_doc_typo
     add b5820a2  [BEAM-12403][BEAM-12348] Add User State Support for Portable SamzaRunner
(#15280)

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  |  41 +++---
 .../beam/runners/samza/runtime/GroupByKeyOp.java   |   4 +-
 .../runners/samza/runtime/SamzaDoFnRunners.java    |  44 ++++++-
 .../samza/runtime/SamzaStateRequestHandlers.java   | 146 ++++++++++++++++++---
 .../samza/runtime/SamzaStoreStateInternals.java    |  58 ++++++--
 .../SplittableParDoProcessKeyedElementsOp.java     |   4 +-
 .../translation/ParDoBoundMultiTranslator.java     |  50 ++++++-
 .../beam/runners/samza/util/StateUtils.java}       |  27 ++--
 .../runtime/SamzaTimerInternalsFactoryTest.java    |   6 +-
 .../runners/portability/samza_runner_test.py       |  20 +--
 11 files changed, 300 insertions(+), 102 deletions(-)
 copy runners/{java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ExecutableStageContext.java
=> samza/src/main/java/org/apache/beam/runners/samza/util/StateUtils.java} (55%)

Mime
View raw message