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 8e2092ba28ad31517d65b3085840e6e9a46c83bf Merge: 8edc18e e1a96eb Author: Robert Bradshaw <[email protected]> AuthorDate: Mon Feb 5 15:32:09 2018 -0800 Merge pull request #4529 from [BEAM-3566] Replace apply_* hooks in DirectRunner with PTransformOverrides [BEAM-3566] Replace apply_* hooks in DirectRunner with PTransformOverrides sdks/python/apache_beam/io/gcp/pubsub_test.py | 58 ++++- sdks/python/apache_beam/pipeline.py | 34 +-- sdks/python/apache_beam/pipeline_test.py | 9 +- .../runners/dataflow/dataflow_runner_test.py | 4 +- .../runners/dataflow/ptransform_overrides.py | 6 +- .../apache_beam/runners/direct/direct_runner.py | 234 ++++++++++++--------- .../runners/direct/helper_transforms.py | 8 +- .../runners/direct/sdf_direct_runner.py | 9 +- sdks/python/apache_beam/runners/sdf_common.py | 15 +- sdks/python/apache_beam/transforms/combiners.py | 39 ++-- 10 files changed, 253 insertions(+), 163 deletions(-) diff --cc sdks/python/apache_beam/pipeline.py index 4c48428,c59a29a..f164bf5 --- a/sdks/python/apache_beam/pipeline.py +++ b/sdks/python/apache_beam/pipeline.py @@@ -61,8 -61,8 +61,9 @@@ from apache_beam.options.pipeline_optio from apache_beam.options.pipeline_options import StandardOptions from apache_beam.options.pipeline_options import TypeOptions from apache_beam.options.pipeline_options_validator import PipelineOptionsValidator +from apache_beam.portability import common_urns from apache_beam.pvalue import PCollection + from apache_beam.pvalue import PDone from apache_beam.runners import PipelineRunner from apache_beam.runners import create_runner from apache_beam.transforms import ptransform -- To stop receiving notification emails like this one, please contact [email protected].
