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:45 UTC
[09/25] gora git commit: * Added dependency to write output to Solr.
* 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 <fu...@gmail.com>
Authored: Thu Jul 16 19:38:37 2015 +0300
Committer: Furkan KAMACI <fu...@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