Minor change at SparkWordCount.java
Project: http://git-wip-us.apache.org/repos/asf/gora/repo Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/8f1acc6d Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/8f1acc6d Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/8f1acc6d Branch: refs/heads/master Commit: 8f1acc6d4ef6c192e8fc06287558b7bc7c39b040 Parents: e817a7f Author: Furkan KAMACI <[email protected]> Authored: Sat Aug 22 22:06:42 2015 +0300 Committer: Furkan KAMACI <[email protected]> Committed: Sat Aug 22 22:06:42 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/gora/examples/spark/SparkWordCount.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/gora/blob/8f1acc6d/gora-core/src/examples/java/org/apache/gora/examples/spark/SparkWordCount.java ---------------------------------------------------------------------- diff --git a/gora-core/src/examples/java/org/apache/gora/examples/spark/SparkWordCount.java b/gora-core/src/examples/java/org/apache/gora/examples/spark/SparkWordCount.java index 837da13..0a84d58 100644 --- a/gora-core/src/examples/java/org/apache/gora/examples/spark/SparkWordCount.java +++ b/gora-core/src/examples/java/org/apache/gora/examples/spark/SparkWordCount.java @@ -86,7 +86,7 @@ public class SparkWordCount { JavaPairRDD<String, WebPage> goraRDD = goraSparkEngine.initialize(sc, inStore); long count = goraRDD.count(); - System.out.println("Total Log Count: " + count); + System.out.println("Total Web page count: " + count); JavaRDD<Tuple2<String, Long>> mappedGoraRdd = goraRDD.values().map(mapFunc);
