Author: lewismc
Date: Fri Mar 29 17:56:13 2013
New Revision: 1462560
URL: http://svn.apache.org/r1462560
Log:
GORA-221 fix Cassandra configuration in gora-tutorial
Modified:
gora/branches/GORA_174/gora-tutorial/conf/gora-cassandra-mapping.xml
gora/branches/GORA_174/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java
Modified: gora/branches/GORA_174/gora-tutorial/conf/gora-cassandra-mapping.xml
URL:
http://svn.apache.org/viewvc/gora/branches/GORA_174/gora-tutorial/conf/gora-cassandra-mapping.xml?rev=1462560&r1=1462559&r2=1462560&view=diff
==============================================================================
--- gora/branches/GORA_174/gora-tutorial/conf/gora-cassandra-mapping.xml
(original)
+++ gora/branches/GORA_174/gora-tutorial/conf/gora-cassandra-mapping.xml Fri
Mar 29 17:56: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/branches/GORA_174/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java
URL:
http://svn.apache.org/viewvc/gora/branches/GORA_174/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java?rev=1462560&r1=1462559&r2=1462560&view=diff
==============================================================================
---
gora/branches/GORA_174/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java
(original)
+++
gora/branches/GORA_174/gora-tutorial/src/main/java/org/apache/gora/tutorial/log/LogAnalytics.java
Fri Mar 29 17:56: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());