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/06/10 15:26:41 UTC

[beam] branch master updated (f7eb5ae02f8 -> c97545092cf)

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 f7eb5ae02f8 [BEAM-14533] Bump cloudpickle to 2.1.0 (#17780)
     add c97545092cf Add basic byte size estimation for batches (#17771)

No new revisions were added by this update.

Summary of changes:
 .../apache_beam/runners/worker/opcounters.py       | 10 ++-
 .../apache_beam/runners/worker/opcounters_test.py  | 25 +++++++
 sdks/python/apache_beam/transforms/cy_combiners.py | 32 ++++++++
 .../cy_dataflow_distribution_counter.pxd           |  2 +
 .../cy_dataflow_distribution_counter.pyx           | 14 ++++
 .../transforms/py_dataflow_distribution_counter.py | 20 +++++
 sdks/python/apache_beam/transforms/window.py       | 11 +++
 sdks/python/apache_beam/typehints/batch.py         | 28 +++++++
 sdks/python/apache_beam/typehints/batch_test.py    | 47 +++++++++++-
 sdks/python/apache_beam/utils/counters.pxd         |  1 +
 sdks/python/apache_beam/utils/counters.py          |  9 +++
 sdks/python/apache_beam/utils/counters_test.py     | 87 ++++++++++++++++++++++
 12 files changed, 281 insertions(+), 5 deletions(-)