You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2018/10/18 09:46:06 UTC
[beam] 01/01: Merge pull request #6717 [BEAM-5521] Re-use bundle
processors across bundles.
This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 61a9f7193f1a61869915da3b4f386b34eac63822
Merge: 90a0363 f9697f3
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Thu Oct 18 11:45:55 2018 +0200
Merge pull request #6717 [BEAM-5521] Re-use bundle processors across bundles.
[BEAM-5521] Re-use bundle processors across bundles.
sdks/python/apache_beam/metrics/cells.py | 12 +++++
sdks/python/apache_beam/metrics/execution.py | 8 ++++
.../apache_beam/runners/worker/bundle_processor.py | 18 +++++++-
.../apache_beam/runners/worker/operations.pxd | 2 +
.../apache_beam/runners/worker/operations.py | 48 +++++++++++++++-----
.../apache_beam/runners/worker/sdk_worker.py | 52 ++++++++++++++--------
.../runners/worker/statesampler_fast.pyx | 5 +++
.../runners/worker/statesampler_slow.py | 4 ++
sdks/python/apache_beam/utils/counters.py | 15 ++++++-
9 files changed, 132 insertions(+), 32 deletions(-)