[beam] branch master updated: Made replaceTransforms protected so that DataflowRunner subclass can properly setup overrides.

[lc...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 151ae67  Made replaceTransforms protected so that DataflowRunner subclass can properly setup overrides.
151ae67 is described below

commit 151ae6792a95f8093e1c798660cac67a6423f587
Author: Jeremie Lenfant-Engelmann <je...@google.com>
AuthorDate: Thu Dec 21 09:24:36 2017 -0800

    Made replaceTransforms protected so that DataflowRunner subclass can properly
    setup overrides.
---
 .../main/java/org/apache/beam/runners/dataflow/DataflowRunner.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
index 3684b47..7b9f1c5 100644
--- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
+++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
@@ -834,8 +834,10 @@ public class DataflowRunner extends PipelineRunner<DataflowPipelineJob> {
         PropertyNames.ENVIRONMENT_VERSION_JOB_TYPE_KEY, jobType);
   }
 
+  // This method is protected to allow a Google internal subclass to properly
+  // setup overrides.
   @VisibleForTesting
-  void replaceTransforms(Pipeline pipeline) {
+  protected void replaceTransforms(Pipeline pipeline) {
     boolean streaming = options.isStreaming() || containsUnboundedPCollection(pipeline);
     // Ensure all outputs of all reads are consumed before potentially replacing any
     // Read PTransforms

-- 
To stop receiving notification emails like this one, please contact
['"commits@beam.apache.org" <co...@beam.apache.org>'].