Minor improvements for LogAnalyticsSpark.java
Project: http://git-wip-us.apache.org/repos/asf/gora/repo Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/9cff3359 Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/9cff3359 Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/9cff3359 Branch: refs/heads/master Commit: 9cff33598231e9cf54060cecf1ccacdf62e64c5b Parents: 8893fd5 Author: Furkan KAMACI <[email protected]> Authored: Sat Aug 22 16:46:55 2015 +0300 Committer: Furkan KAMACI <[email protected]> Committed: Sat Aug 22 16:46:55 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/gora/tutorial/log/LogAnalyticsSpark.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/gora/blob/9cff3359/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalyticsSpark.java ---------------------------------------------------------------------- diff --git a/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalyticsSpark.java b/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalyticsSpark.java index 59e7c79..84bb693 100644 --- a/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalyticsSpark.java +++ b/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalyticsSpark.java @@ -155,10 +155,10 @@ public class LogAnalyticsSpark { Pageview.class); SparkConf sparkConf = new SparkConf().setAppName( - "Gora Integration Application").setMaster("local"); + "Gora Spark Integration Application").setMaster("local"); Class[] c = new Class[1]; - c[0] = Pageview.class; + c[0] = inStore.getPersistentClass(); sparkConf.registerKryoClasses(c); // JavaSparkContext sc = new JavaSparkContext(sparkConf);
