You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gora.apache.org by le...@apache.org on 2015/09/03 09:28:51 UTC
[15/25] gora git commit: Minor improvements for LogAnalyticsSpark.java
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 <fu...@gmail.com>
Authored: Sat Aug 22 16:46:55 2015 +0300
Committer: Furkan KAMACI <fu...@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);