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:05 UTC
[beam] branch master updated (90a0363 -> 61a9f71)
This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 90a0363 Merge pull request #6722 Clean up a couple of Cython warnings.
add f9697f3 [BEAM-5521] Re-use bundle processors across bundles.
new 61a9f71 Merge pull request #6717 [BEAM-5521] Re-use bundle processors across bundles.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
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(-)
[beam] 01/01: Merge pull request #6717 [BEAM-5521] Re-use bundle
processors across bundles.
Posted by ro...@apache.org.
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(-)