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 fdaf5d8 Revert "[BEAM-9085] Fix performance regression in SyntheticSource (#10885)" (#10924) add c6f812f [BEAM-8537] Provide WatermarkEstimator to track watermark (#10375) No new revisions were added by this update. Summary of changes: sdks/python/apache_beam/io/iobase.py | 35 +++++ sdks/python/apache_beam/io/watermark_estimators.py | 150 +++++++++++++++++++++ .../apache_beam/io/watermark_estimators_test.py | 106 +++++++++++++++ sdks/python/apache_beam/runners/common.pxd | 17 +-- sdks/python/apache_beam/runners/common.py | 119 ++++++++++------ .../runners/direct/sdf_direct_runner.py | 7 +- .../runners/portability/fn_api_runner_test.py | 11 +- sdks/python/apache_beam/runners/sdf_utils.py | 133 +++++++++++++----- sdks/python/apache_beam/runners/sdf_utils_test.py | 26 ++++ .../apache_beam/runners/worker/bundle_processor.py | 27 +++- sdks/python/apache_beam/transforms/core.py | 77 ++++------- sdks/python/apache_beam/transforms/core_test.py | 55 -------- 12 files changed, 563 insertions(+), 200 deletions(-) create mode 100644 sdks/python/apache_beam/io/watermark_estimators.py create mode 100644 sdks/python/apache_beam/io/watermark_estimators_test.py delete mode 100644 sdks/python/apache_beam/transforms/core_test.py