Repository: incubator-beam Updated Branches: refs/heads/master df1d5f61e -> b4c123cd4
[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/d8c01c8b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d8c01c8b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d8c01c8b Branch: refs/heads/master Commit: d8c01c8b5453be750c1deae123ecb8cbb9b833c2 Parents: 2d3d0f4 Author: Ismaël MejÃa <[email protected]> Authored: Wed Jun 29 23:12:06 2016 +0200 Committer: Aljoscha Krettek <[email protected]> Committed: Fri Jul 1 07:50:35 2016 +0200 ---------------------------------------------------------------------- .../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/d8c01c8b/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/d8c01c8b/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);
