You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2020/07/18 00:08:33 UTC
[beam] branch master updated (abf63e2 -> ac6d80e)
This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from abf63e2 Merge pull request #12288 from aaltay/matchers
add ac6d80e [BEAM-10420] Add support for per window invocation of beam:transform:sdf_process_sized_element_and_restrictions:v1 (#12275)
No new revisions were added by this update.
Summary of changes:
sdks/python/apache_beam/io/iobase.py | 13 +-
sdks/python/apache_beam/io/restriction_trackers.py | 3 +
sdks/python/apache_beam/runners/common.pxd | 4 +
sdks/python/apache_beam/runners/common.py | 370 ++++++++++++++----
sdks/python/apache_beam/runners/common_test.py | 423 +++++++++++++++++++++
.../apache_beam/runners/worker/bundle_processor.py | 23 +-
.../runners/worker/bundle_processor_test.py | 17 +-
.../apache_beam/runners/worker/operations.py | 17 +-
8 files changed, 766 insertions(+), 104 deletions(-)