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 784f17e Merge pull request #5873: [BEAM-4453] Add schema support for
Java POJOs and Java Beans
add 4b2f31f Add per_element_output_counter to python SDK
add bc5d53a Change experimental flag name to 'per_element_instrumentation'
add cc0073e Added cython annotation to _OutputProcessor since cython
annotation is not transitive
add f14dbfb41 Change reading 'outputs_per_element_counter' experimental
flag into new pattern.
add e04cf83 Avoid silent error when calling unimplemented function.
add 0c4b9c5 Avoid silent error when calling unimplemented function.
new a8eaa1b Merge pull request #4741 from boyuanzz/output_counter
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/runners/common.pxd | 11 +++++-
sdks/python/apache_beam/runners/common.py | 43 ++++++++++++++++++++--
.../apache_beam/runners/worker/operations.py | 3 +-
.../cy_dataflow_distribution_counter.pxd | 1 +
.../cy_dataflow_distribution_counter.pyx | 3 ++
.../transforms/py_dataflow_distribution_counter.py | 3 ++
6 files changed, 58 insertions(+), 6 deletions(-)