This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 188915f8f6848f9d16455eec992bc7ec27cc5ebf
Merge: ca37470 5c4a2e9
Author: Pablo <pabl...@users.noreply.github.com>
AuthorDate: Fri Oct 12 16:58:15 2018 -0700
Merge pull request #6205 from ajamato/metrics_protos_impl
[BEAM-4374] Implementing a subset of the new metrics framework in python.
.../fn-execution/src/main/proto/beam_fn_api.proto | 59 ++++-
.../src/main/proto/metric_definitions.yaml | 57 +++++
sdks/python/apache_beam/metrics/cells.py | 27 +++
sdks/python/apache_beam/metrics/execution.py | 27 +++
.../python/apache_beam/metrics/monitoring_infos.py | 246 +++++++++++++++++++++
sdks/python/apache_beam/portability/common_urns.py | 6 +
.../runners/portability/fn_api_runner.py | 95 +++++---
.../runners/portability/fn_api_runner_test.py | 108 ++++++++-
.../apache_beam/runners/worker/bundle_processor.py | 27 ++-
.../apache_beam/runners/worker/operations.pxd | 7 +-
.../apache_beam/runners/worker/operations.py | 70 ++++++
.../apache_beam/runners/worker/sdk_worker.py | 6 +-
.../runners/worker/statesampler_fast.pyx | 3 +
.../runners/worker/statesampler_slow.py | 3 +
14 files changed, 692 insertions(+), 49 deletions(-)
