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/02/21 19:18:50 UTC

[beam] branch master updated (fdaf5d8 -> c6f812f)

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