gora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lewi...@apache.org
Subject [25/25] gora git commit: GORA-386 Gora Spark Backend Support - Final update of LogAnalyticsSpark to comply with forbidden-api plugin
Date Thu, 03 Sep 2015 07:29:01 GMT
GORA-386 Gora Spark Backend Support - Final update of LogAnalyticsSpark to comply with forbidden-api
plugin


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

Branch: refs/heads/master
Commit: ea44388f9883218f7314ed4bec51e3f2115cf33f
Parents: 7c6a63e
Author: Lewis John McGibbney <lewis.j.mcgibbney@jpl.nasa.gov>
Authored: Thu Sep 3 00:29:30 2015 -0700
Committer: Lewis John McGibbney <lewis.j.mcgibbney@jpl.nasa.gov>
Committed: Thu Sep 3 00:29:30 2015 -0700

----------------------------------------------------------------------
 CHANGES.txt                                                    | 2 ++
 .../java/org/apache/gora/tutorial/log/LogAnalyticsSpark.java   | 6 +++---
 2 files changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/gora/blob/ea44388f/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 86d78b2..3f7e94d 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -4,6 +4,8 @@
 
 Current Development
 
+* GORA-386 Gora Spark Backend Support (Furkan KAMACI, talat, lewismc)
+
 * GORA-429 Implement Maven forbidden-apis plugin in Gora (lewismc, rmarroquin)
 
 * GORA-228 java.util.ConcurrentModificationException when using MemStore for concurrent tests
(Yasin Kılınç, cihad güzel, lewismc)

http://git-wip-us.apache.org/repos/asf/gora/blob/ea44388f/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 84bb693..cdd245c 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
@@ -107,7 +107,7 @@ public class LogAnalyticsSpark {
 
   public static void main(String[] args) throws Exception {
     if (args.length < 2) {
-      System.err.println(USAGE);
+      log.error(USAGE);
       System.exit(1);
     }
 
@@ -166,7 +166,7 @@ public class LogAnalyticsSpark {
     JavaPairRDD<Long, Pageview> goraRDD = goraSparkEngine.initialize(sc, inStore);
 
     long count = goraRDD.count();
-    System.out.println("Total Log Count: " + count);
+    log.info("Total Log Count: {}", count);
 
     JavaRDD<Tuple2<Tuple2<String, Long>, Long>> mappedGoraRdd = goraRDD
         .values().map(mapFunc);
@@ -174,7 +174,7 @@ public class LogAnalyticsSpark {
     JavaPairRDD<String, MetricDatum> reducedGoraRdd = JavaPairRDD
         .fromJavaRDD(mappedGoraRdd).reduceByKey(redFunc).mapToPair(metricFunc);
 
-    System.out.println("MetricDatum count:" + reducedGoraRdd.count());
+    log.info("MetricDatum count: {}", reducedGoraRdd.count());
 
     //Print output for debug purpose
     /*


Mime
View raw message