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

Posted to commits@beam.apache.org by pa...@apache.org on 2023/02/16 21:18:34 UTC

[beam] branch master updated (c210df3d3b3 -> 545a2e63ca7)

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

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


    from c210df3d3b3 Fix interface{} in iter& emit type of DoFn in Go (#25203)
     add 545a2e63ca7 Task #25064: Python SDK Data sampling implementation (#25093)

No new revisions were added by this update.

Summary of changes:
 .../apache_beam/runners/worker/bundle_processor.py |  95 +++++++++-
 .../runners/worker/bundle_processor_test.py        | 132 ++++++++++++++
 .../apache_beam/runners/worker/data_sampler.py     | 156 +++++++++++++++++
 .../runners/worker/data_sampler_test.py            | 192 +++++++++++++++++++++
 .../apache_beam/runners/worker/sdk_worker.py       |  34 +++-
 .../apache_beam/runners/worker/sdk_worker_main.py  |   9 +-
 .../apache_beam/runners/worker/sdk_worker_test.py  |  55 +++++-
 sdks/python/apache_beam/transforms/environments.py |   1 +
 8 files changed, 664 insertions(+), 10 deletions(-)
 create mode 100644 sdks/python/apache_beam/runners/worker/data_sampler.py
 create mode 100644 sdks/python/apache_beam/runners/worker/data_sampler_test.py