Author: gsingers
Date: Fri Oct 31 10:28:48 2008
New Revision: 709494
URL: http://svn.apache.org/viewvc?rev=709494&view=rev
Log:
MAHOUT-91: fix input key type
Modified:
lucene/mahout/trunk/examples/src/main/java/org/apache/mahout/classifier/bayes/WikipediaDatasetCreatorMapper.java
Modified:
lucene/mahout/trunk/examples/src/main/java/org/apache/mahout/classifier/bayes/WikipediaDatasetCreatorMapper.java
URL:
http://svn.apache.org/viewvc/lucene/mahout/trunk/examples/src/main/java/org/apache/mahout/classifier/bayes/WikipediaDatasetCreatorMapper.java?rev=709494&r1=709493&r2=709494&view=diff
==============================================================================
---
lucene/mahout/trunk/examples/src/main/java/org/apache/mahout/classifier/bayes/WikipediaDatasetCreatorMapper.java
(original)
+++
lucene/mahout/trunk/examples/src/main/java/org/apache/mahout/classifier/bayes/WikipediaDatasetCreatorMapper.java
Fri Oct 31 10:28:48 2008
@@ -20,6 +20,7 @@
import org.apache.commons.lang.StringEscapeUtils;
import org.apache.hadoop.io.DefaultStringifier;
import org.apache.hadoop.io.Text;
+import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapred.JobConf;
import org.apache.hadoop.mapred.MapReduceBase;
import org.apache.hadoop.mapred.Mapper;
@@ -39,11 +40,11 @@
import java.util.Set;
public class WikipediaDatasetCreatorMapper extends MapReduceBase implements
- Mapper<Text, Text, Text, Text> {
+ Mapper<LongWritable, Text, Text, Text> {
private static Set<String> countries = null;
- public void map(Text key, Text value,
+ public void map(LongWritable key, Text value,
OutputCollector<Text, Text> output, Reporter reporter)
throws IOException {
String document = value.toString();