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

Posted to commits@beam.apache.org by pa...@apache.org on 2021/03/30 21:28:53 UTC

[beam] branch master updated (7eff49f -> a0a8666)

This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 7eff49f  Merge pull request #14378: [BEAM-7093] Add Spark 3 and Java 11 info into the CHANGES file
     add a0a8666  Merge pull request #13985 from [BEAM-11810] A trigger manager for FnApiRunner

No new revisions were added by this update.

Summary of changes:
 .../portability/fn_api_runner/trigger_manager.py   | 458 +++++++++++++++++++++
 .../fn_api_runner/trigger_manager_test.py          | 250 +++++++++++
 sdks/python/apache_beam/transforms/trigger.py      |  11 +-
 .../apache_beam/transforms/userstate_test.py       |  39 ++
 sdks/python/apache_beam/utils/timestamp.py         |   4 +
 5 files changed, 756 insertions(+), 6 deletions(-)
 create mode 100644 sdks/python/apache_beam/runners/portability/fn_api_runner/trigger_manager.py
 create mode 100644 sdks/python/apache_beam/runners/portability/fn_api_runner/trigger_manager_test.py