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 a8eaa1b3ec0544de8b56dd504bc249d4c1a2017f Merge: 784f17e 0c4b9c5 Author: Robert Bradshaw <[email protected]> AuthorDate: Mon Jul 9 11:42:33 2018 -0700 Merge pull request #4741 from boyuanzz/output_counter Add per_element_output_counter to python SDK 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(-) diff --cc sdks/python/apache_beam/runners/common.py index 03333a8,3f9d77e..d5f35de --- a/sdks/python/apache_beam/runners/common.py +++ b/sdks/python/apache_beam/runners/common.py @@@ -23,19 -22,13 +23,20 @@@ For internal use only; no backwards-compatibility guarantees. """ +from __future__ import absolute_import + import sys import traceback +from builtins import next +from builtins import object +from builtins import zip -import six +from future.utils import raise_ +from past.builtins import basestring +from past.builtins import unicode from apache_beam.internal import util + from apache_beam.options.value_provider import RuntimeValueProvider from apache_beam.pvalue import TaggedOutput from apache_beam.transforms import DoFn from apache_beam.transforms import core
