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 <[email protected]> Authored: Tue Aug 9 15:27:20 2016 -0700 Committer: Mark Liu <[email protected]> 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"; } } }
