mahout-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sro...@apache.org
Subject svn commit: r659903 - /lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderJob.java
Date Sun, 25 May 2008 03:30:33 GMT
Author: srowen
Date: Sat May 24 20:30:32 2008
New Revision: 659903

URL: http://svn.apache.org/viewvc?rev=659903&view=rev
Log:
Minor fixes to job config

Modified:
    lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderJob.java

Modified: lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderJob.java
URL: http://svn.apache.org/viewvc/lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderJob.java?rev=659903&r1=659902&r2=659903&view=diff
==============================================================================
--- lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderJob.java
(original)
+++ lucene/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderJob.java
Sat May 24 20:30:32 2008
@@ -76,13 +76,12 @@
     Path userIDFilePath = new Path(userIDFile);
     Path outputPathPath = new Path(outputPath);
 
-    JobConf jobConf = new JobConf(Recommender.class);
+    JobConf jobConf = new JobConf(RecommenderJob.class);
 
     FileSystem fs = FileSystem.get(jobConf);
     if (fs.exists(outputPathPath)) {
       fs.delete(outputPathPath);
     }
-    fs.mkdirs(outputPathPath);
 
     jobConf.set(RecommenderMapper.RECOMMENDER_CLASS_NAME, recommendClassName);
     jobConf.set(RecommenderMapper.RECOMMENDATIONS_PER_USER, String.valueOf(recommendationsPerUser));



Mime
View raw message