This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from dbdf4ad Merge pull request #14106 from pabloem/try-dash
new 7a27c79 Revert "Revert "[BEAM-2914] Add portable merging window
support to Python. (#12995)""
new 9839525 Use the windowing strategy of the input, not output,
PCollection of GBK.
new 31368b54 Improve test, error on ALREADY_MERGED.
new 9035a92 Merge pull request #14095 from robertwb/merging-windows
The 30874 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../runners/portability/flink_runner_test.py | 3 +
.../runners/portability/fn_api_runner/execution.py | 248 +++++++++++++++++++--
.../portability/fn_api_runner/fn_runner_test.py | 37 +++
.../runners/portability/spark_runner_test.py | 3 +
.../apache_beam/runners/worker/bundle_processor.py | 43 ++++
5 files changed, 321 insertions(+), 13 deletions(-)
