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 <[email protected]>
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
['"[email protected]" <[email protected]>'].
