beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [37/50] [abbrv] incubator-beam git commit: [BEAM-392] Rename missing references to FlinkPipelineRunner
Date Wed, 06 Jul 2016 17:20:43 GMT
[BEAM-392] Rename missing references to FlinkPipelineRunner


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/acec0a59
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/acec0a59
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/acec0a59

Branch: refs/heads/runners-spark2
Commit: acec0a5984ef7e7dd73f943afe25d35f0f828d6b
Parents: 721763a
Author: Ismaël Mejía <iemejia@gmail.com>
Authored: Wed Jun 29 23:12:06 2016 +0200
Committer: Luke Cwik <lcwik@google.com>
Committed: Wed Jul 6 10:18:52 2016 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/beam/examples/MinimalWordCount.java   | 6 +++---
 .../java/org/apache/beam/examples/MinimalWordCountJava8.java   | 6 +++---
 2 files changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/acec0a59/examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java
----------------------------------------------------------------------
diff --git a/examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java b/examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java
index 2c67609..9f6d61a 100644
--- a/examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java
+++ b/examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java
@@ -67,17 +67,17 @@ public class MinimalWordCount {
     // In order to run your pipeline, you need to make following runner specific changes:
     //
     // CHANGE 1/3: Select a Beam runner, such as BlockingDataflowRunner
-    // or FlinkPipelineRunner.
+    // or FlinkRunner.
     // CHANGE 2/3: Specify runner-required options.
     // For BlockingDataflowRunner, set project and temp location as follows:
     //   DataflowPipelineOptions dataflowOptions = options.as(DataflowPipelineOptions.class);
     //   dataflowOptions.setRunner(BlockingDataflowRunner.class);
     //   dataflowOptions.setProject("SET_YOUR_PROJECT_ID_HERE");
     //   dataflowOptions.setTempLocation("gs://SET_YOUR_BUCKET_NAME_HERE/AND_TEMP_DIRECTORY");
-    // For FlinkPipelineRunner, set the runner as follows. See {@code FlinkPipelineOptions}
+    // For FlinkRunner, set the runner as follows. See {@code FlinkPipelineOptions}
     // for more details.
     //   options.as(FlinkPipelineOptions.class)
-    //      .setRunner(FlinkPipelineRunner.class);
+    //      .setRunner(FlinkRunner.class);
 
     // Create the Pipeline object with the options we defined above.
     Pipeline p = Pipeline.create(options);

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/acec0a59/examples/java8/src/main/java/org/apache/beam/examples/MinimalWordCountJava8.java
----------------------------------------------------------------------
diff --git a/examples/java8/src/main/java/org/apache/beam/examples/MinimalWordCountJava8.java
b/examples/java8/src/main/java/org/apache/beam/examples/MinimalWordCountJava8.java
index 6362b96..ff8ca55 100644
--- a/examples/java8/src/main/java/org/apache/beam/examples/MinimalWordCountJava8.java
+++ b/examples/java8/src/main/java/org/apache/beam/examples/MinimalWordCountJava8.java
@@ -42,17 +42,17 @@ public class MinimalWordCountJava8 {
     // In order to run your pipeline, you need to make following runner specific changes:
     //
     // CHANGE 1/3: Select a Beam runner, such as BlockingDataflowRunner
-    // or FlinkPipelineRunner.
+    // or FlinkRunner.
     // CHANGE 2/3: Specify runner-required options.
     // For BlockingDataflowRunner, set project and temp location as follows:
     //   DataflowPipelineOptions dataflowOptions = options.as(DataflowPipelineOptions.class);
     //   dataflowOptions.setRunner(BlockingDataflowRunner.class);
     //   dataflowOptions.setProject("SET_YOUR_PROJECT_ID_HERE");
     //   dataflowOptions.setTempLocation("gs://SET_YOUR_BUCKET_NAME_HERE/AND_TEMP_DIRECTORY");
-    // For FlinkPipelineRunner, set the runner as follows. See {@code FlinkPipelineOptions}
+    // For FlinkRunner, set the runner as follows. See {@code FlinkPipelineOptions}
     // for more details.
     //   options.as(FlinkPipelineOptions.class)
-    //      .setRunner(FlinkPipelineRunner.class);
+    //      .setRunner(FlinkRunner.class);
 
     Pipeline p = Pipeline.create(options);
 


Mime
View raw message