You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/07/06 17:20:43 UTC
[37/50] [abbrv] incubator-beam git commit: [BEAM-392] Rename missing
references to FlinkPipelineRunner
[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 <ie...@gmail.com>
Authored: Wed Jun 29 23:12:06 2016 +0200
Committer: Luke Cwik <lc...@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);