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

Posted to commits@beam.apache.org by bh...@apache.org on 2022/05/04 22:31:40 UTC

[beam] branch master updated (228fd1a0021 -> 1c4418ce463)

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

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


    from 228fd1a0021 Merge pull request #17499 from ihji/BEAM-9245
     add 1c4418ce463 [BEAM-14294] Worker changes to support trivial Batched DoFns (#17384)

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/coders/fast_coders_test.py |   2 +-
 sdks/python/apache_beam/runners/common.pxd         |  15 +-
 sdks/python/apache_beam/runners/common.py          | 505 ++++++++++++++++-----
 .../portability/fn_api_runner/fn_runner_test.py    | 202 +++++++++
 .../runners/portability/portable_runner_test.py    |   5 +
 .../apache_beam/runners/worker/bundle_processor.py |  32 +-
 .../apache_beam/runners/worker/opcounters.pxd      |   2 +
 .../apache_beam/runners/worker/opcounters.py       |  17 +-
 .../apache_beam/runners/worker/operations.pxd      |  22 +-
 .../apache_beam/runners/worker/operations.py       | 282 ++++++++++--
 .../apache_beam/transforms/batch_dofn_test.py      |  14 +
 sdks/python/apache_beam/transforms/combiners.py    |   4 +-
 .../apache_beam/transforms/ptransform_test.py      |   8 +-
 sdks/python/apache_beam/typehints/batch.py         |   6 +
 sdks/python/apache_beam/utils/windowed_value.pxd   |   8 +
 sdks/python/apache_beam/utils/windowed_value.py    | 129 +++++-
 .../apache_beam/utils/windowed_value_test.py       |  92 ++++
 17 files changed, 1155 insertions(+), 190 deletions(-)