gora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lewi...@apache.org
Subject [03/25] gora git commit: * Serialization support via Kyro.
Date Thu, 03 Sep 2015 07:28:39 GMT
* Serialization support via Kyro.


Project: http://git-wip-us.apache.org/repos/asf/gora/repo
Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/8fbdef7d
Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/8fbdef7d
Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/8fbdef7d

Branch: refs/heads/master
Commit: 8fbdef7de963defb1387f0fbbe9e56506b627ba3
Parents: ef68cea
Author: Furkan KAMACI <furkankamaci@gmail.com>
Authored: Sun Jun 28 18:49:13 2015 +0300
Committer: Furkan KAMACI <furkankamaci@gmail.com>
Committed: Sun Jun 28 18:49:13 2015 +0300

----------------------------------------------------------------------
 .../org/apache/gora/tutorial/log/LogAnalyticsSpark.java   | 10 ++++++++++
 1 file changed, 10 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/gora/blob/8fbdef7d/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 9b28fd7..0194c3b 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
@@ -51,6 +51,12 @@ public class LogAnalyticsSpark {
 
     SparkConf sparkConf = new SparkConf().setAppName(
         "Gora Integration Application").setMaster("local");
+      
+    //todo _fk change architectural desigm
+    Class[] c = new Class[1];
+    c[0] = Pageview.class;
+    sparkConf.registerKryoClasses(c);
+    //
     JavaSparkContext sc = new JavaSparkContext(sparkConf);
 
     Configuration hadoopConf = new Configuration();
@@ -64,6 +70,10 @@ public class LogAnalyticsSpark {
 
     long count = goraRDD.count();
     System.out.println("Total Count: " + count);
+
+    String firstOneURL = goraRDD.first()._2().getUrl().toString();
+    System.out.println(firstOneURL);
+
     return 1;
   }
 }


Mime
View raw message