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/02/05 23:32:14 UTC
[beam] 01/01: Merge pull request #4529 from [BEAM-3566] Replace
apply_* hooks in DirectRunner with PTransformOverrides
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 <ro...@gmail.com>
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
robertwb@apache.org.