* 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 <[email protected]> Authored: Sun Jun 28 18:49:13 2015 +0300 Committer: Furkan KAMACI <[email protected]> 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; } }
