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:13 UTC
[beam] branch master updated (8edc18e -> 8e2092b)
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 8edc18e Merge pull request #4595: [BEAM-3601] Switch to Java 8 futures
add 16e5fef [BEAM-3566] Replace apply_* hooks in DirectRunner with PTransformOverrides
add e1a96eb Address reviewer comments
new 8e2092b Merge pull request #4529 from [BEAM-3566] Replace apply_* hooks in DirectRunner with PTransformOverrides
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/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(-)
--
To stop receiving notification emails like this one, please contact
robertwb@apache.org.
[beam] 01/01: Merge pull request #4529 from [BEAM-3566] Replace
apply_* hooks in DirectRunner with PTransformOverrides
Posted by ro...@apache.org.
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.