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 2013/03/29 18:08:13 UTC
svn commit: r1462541 - in /gora/trunk: CHANGES.txt
gora-tutorial/conf/gora-cassandra-mapping.xml
gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java
Author: lewismc
Date: Fri Mar 29 17:08:13 2013
New Revision: 1462541
URL: http://svn.apache.org/r1462541
Log:
GORA-221 fix Cassandra configuration in gora-tutorial
Modified:
gora/trunk/CHANGES.txt
gora/trunk/gora-tutorial/conf/gora-cassandra-mapping.xml
gora/trunk/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java
Modified: gora/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/gora/trunk/CHANGES.txt?rev=1462541&r1=1462540&r2=1462541&view=diff
==============================================================================
--- gora/trunk/CHANGES.txt (original)
+++ gora/trunk/CHANGES.txt Fri Mar 29 17:08:13 2013
@@ -6,6 +6,8 @@ Gora Change Log
trunk (current development)
+* GORA-221 fix Cassandra configuration in gora-tutorial (lewismc)
+
* GORA-211 thread safety: fix java.lang.NullPointerException - synchronize on mutator (rherget)
* GORA-210 thread safety: fix java.util.ConcurrentModificationException (rherget)
Modified: gora/trunk/gora-tutorial/conf/gora-cassandra-mapping.xml
URL: http://svn.apache.org/viewvc/gora/trunk/gora-tutorial/conf/gora-cassandra-mapping.xml?rev=1462541&r1=1462540&r2=1462541&view=diff
==============================================================================
--- gora/trunk/gora-tutorial/conf/gora-cassandra-mapping.xml (original)
+++ gora/trunk/gora-tutorial/conf/gora-cassandra-mapping.xml Fri Mar 29 17:08:13 2013
@@ -26,6 +26,10 @@
<family name="http"/>
<family name="misc"/>
</keyspace>
+
+ <keyspace name="Metrics" cluster="Test Cluster" host="localhost">
+ <family name="common"/>
+ </keyspace>
<class name="org.apache.gora.tutorial.log.generated.Pageview" keyClass="java.lang.Long" keyspace="Pageview">
<field name="url" family="common" qualifier="url"/>
@@ -38,7 +42,7 @@
<field name="userAgent" family="misc" qualifier="userAgent"/>
</class>
- <class name="org.apache.gora.tutorial.log.generated.MetricDatum" keyClass="java.lang.String" keyspace="Pageview">
+ <class name="org.apache.gora.tutorial.log.generated.MetricDatum" keyClass="java.lang.String" keyspace="Metrics">
<field name="metricDimension" family="common" qualifier="metricDimension"/>
<field name="timestamp" family="common" qualifier="ts"/>
<field name="metric" family="common" qualifier="metric"/>
Modified: gora/trunk/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java
URL: http://svn.apache.org/viewvc/gora/trunk/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java?rev=1462541&r1=1462540&r2=1462541&view=diff
==============================================================================
--- gora/trunk/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java (original)
+++ gora/trunk/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java Fri Mar 29 17:08:13 2013
@@ -139,6 +139,7 @@ public class LogAnalytics extends Config
DataStore<String, MetricDatum> outStore, int numReducer) throws IOException {
Job job = new Job(getConf());
job.setJobName("Log Analytics");
+ log.info("Creating Hadoop Job: " + job.getJobName());
job.setNumReduceTasks(numReducer);
job.setJarByClass(getClass());