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 2022/12/07 20:13:54 UTC

[beam] branch master updated (6c24637b451 -> 11ed0e1857f)

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 6c24637b451 fix go lints (#24566)
     add 11ed0e1857f Samza runner support for non unique stateId across multiple ParDos (#24276)

No new revisions were added by this update.

Summary of changes:
 runners/samza/build.gradle                         |   4 -
 .../org/apache/beam/runners/samza/SamzaRunner.java |   8 +-
 .../apache/beam/runners/samza/runtime/DoFnOp.java  |   6 +-
 .../runners/samza/runtime/SamzaDoFnRunners.java    |  10 +-
 .../samza/runtime/SamzaStoreStateInternals.java    |  40 +++---
 .../runners/samza/translation/ConfigBuilder.java   |   5 +-
 .../runners/samza/translation/ConfigContext.java   |  13 +-
 .../translation/ParDoBoundMultiTranslator.java     |  32 ++---
 .../translation/PortableTranslationContext.java    |   2 +-
 .../samza/translation/SamzaPipelineTranslator.java |   4 +-
 .../runners/samza/translation/StateIdParser.java   |  69 ++++++++++
 .../samza/translation/TranslationContext.java      |   8 ++
 .../samza/util/SamzaPipelineTranslatorUtils.java   |   4 +-
 .../beam/runners/samza/util/StoreIdGenerator.java  |  48 +++++++
 .../runtime/SamzaStoreStateInternalsTest.java      | 102 ++++++++++++++
 .../samza/translation/ConfigGeneratorTest.java     | 146 +++++++++++++++++++--
 .../samza/translation/TranslationContextTest.java  |   6 +-
 17 files changed, 428 insertions(+), 79 deletions(-)
 create mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/StateIdParser.java
 create mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/util/StoreIdGenerator.java