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 <[email protected]> Authored: Thu Sep 3 00:29:30 2015 -0700 Committer: Lewis John McGibbney <[email protected]> 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 /*
