* Added dependency to write output to Solr.
Project: http://git-wip-us.apache.org/repos/asf/gora/repo Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/cf6e7658 Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/cf6e7658 Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/cf6e7658 Branch: refs/heads/master Commit: cf6e76585b18ff926f8e7e4928f2d7cd28ac7c6f Parents: c111e62 Author: Furkan KAMACI <furkankam...@gmail.com> Authored: Thu Jul 16 19:38:37 2015 +0300 Committer: Furkan KAMACI <furkankam...@gmail.com> Committed: Thu Jul 16 19:38:37 2015 +0300 ---------------------------------------------------------------------- gora-tutorial/pom.xml | 5 +++++ .../java/org/apache/gora/tutorial/log/LogAnalyticsSpark.java | 6 +++--- 2 files changed, 8 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/gora/blob/cf6e7658/gora-tutorial/pom.xml ---------------------------------------------------------------------- diff --git a/gora-tutorial/pom.xml b/gora-tutorial/pom.xml index 1a13083..5a775b3 100644 --- a/gora-tutorial/pom.xml +++ b/gora-tutorial/pom.xml @@ -108,6 +108,11 @@ <artifactId>gora-cassandra</artifactId> </dependency> + <dependency> + <groupId>org.apache.gora</groupId> + <artifactId>gora-solr</artifactId> + </dependency> + <!--dependency> <groupId>org.apache.gora</groupId> <artifactId>gora-sql</artifactId> </dependency> <dependency> <groupId>org.apache.gora</groupId> <artifactId>gora-solr</artifactId> </dependency --> http://git-wip-us.apache.org/repos/asf/gora/blob/cf6e7658/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 828939e..372c124 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 @@ -17,8 +17,6 @@ */ package org.apache.gora.tutorial.log; -import java.util.Map; - import org.apache.gora.mapreduce.GoraMapReduceUtils; import org.apache.gora.mapreduce.GoraOutputFormat; import org.apache.gora.persistency.Persistent; @@ -158,7 +156,7 @@ public class LogAnalyticsSpark { System.out.println("Total Log Count: " + count); String firstOneURL = goraRDD.first()._2().getUrl().toString(); - System.out.println(firstOneURL); + System.out.println("First entry's first URL:" + firstOneURL); JavaRDD<Tuple2<Tuple2<String, Long>, Long>> mappedGoraRdd = goraRDD .values().map(mapFunc); @@ -169,10 +167,12 @@ public class LogAnalyticsSpark { System.out.println("MetricDatum count:" + reducedGoraRdd.count()); //print screen output + /* Map<String, MetricDatum> metricDatumMap = reducedGoraRdd.collectAsMap(); for (String key : metricDatumMap.keySet()) { System.out.println(key); } + */ // //write output to datastore