You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/08/25 18:55:38 UTC
[24/50] incubator-beam git commit: Change WordCount default input
Change WordCount default input
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e979c826
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e979c826
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e979c826
Branch: refs/heads/gearpump-runner
Commit: e979c826873b61f55c296cc07262829d63610a99
Parents: 9983ff9
Author: Mark Liu <ma...@markliu-macbookpro.roam.corp.google.com>
Authored: Tue Aug 9 15:27:20 2016 -0700
Committer: Mark Liu <ma...@markliu-macbookpro.roam.corp.google.com>
Committed: Tue Aug 9 15:28:24 2016 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/beam/examples/WordCount.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e979c826/examples/java/src/main/java/org/apache/beam/examples/WordCount.java
----------------------------------------------------------------------
diff --git a/examples/java/src/main/java/org/apache/beam/examples/WordCount.java b/examples/java/src/main/java/org/apache/beam/examples/WordCount.java
index d136b88..72ad35f 100644
--- a/examples/java/src/main/java/org/apache/beam/examples/WordCount.java
+++ b/examples/java/src/main/java/org/apache/beam/examples/WordCount.java
@@ -39,6 +39,7 @@ import org.apache.beam.sdk.values.KV;
import org.apache.beam.sdk.values.PCollection;
import com.google.common.base.Strings;
+import com.google.common.io.Resources;
import java.io.IOException;
@@ -204,16 +205,16 @@ public class WordCount {
* <li>SparkRunner:
* .../src/test/resources/LICENSE</li>
* <li>other runners:
- * gs://dataflow-samples/apache/LICENSE</li>
+ * gs://apache-beam-samples/apache/LICENSE</li>
* </ul>
*/
public static class InputFactory implements DefaultValueFactory<String> {
@Override
public String create(PipelineOptions options) {
if (options.getRunner().isAssignableFrom(SparkRunner.class)) {
- return WordCount.class.getClass().getResource("/LICENSE").getPath();
+ return Resources.getResource("LICENSE").getPath();
} else {
- return "gs://dataflow-samples/apache/LICENSE";
+ return "gs://apache-beam-samples/apache/LICENSE";
}
}
}