gora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lewi...@apache.org
Subject [15/25] gora git commit: Minor improvements for LogAnalyticsSpark.java
Date Thu, 03 Sep 2015 07:28:51 GMT
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 <furkankamaci@gmail.com>
Authored: Sat Aug 22 16:46:55 2015 +0300
Committer: Furkan KAMACI <furkankamaci@gmail.com>
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);


Mime
View raw message