You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2009/10/23 04:48:03 UTC

svn commit: r828920 - /incubator/hama/trunk/src/examples/org/apache/hama/examples/CosineSimilarityMatrix.java

Author: edwardyoon
Date: Fri Oct 23 02:48:03 2009
New Revision: 828920

URL: http://svn.apache.org/viewvc?rev=828920&view=rev
Log:
trivial bug of path commit.

Modified:
    incubator/hama/trunk/src/examples/org/apache/hama/examples/CosineSimilarityMatrix.java

Modified: incubator/hama/trunk/src/examples/org/apache/hama/examples/CosineSimilarityMatrix.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/examples/org/apache/hama/examples/CosineSimilarityMatrix.java?rev=828920&r1=828919&r2=828920&view=diff
==============================================================================
--- incubator/hama/trunk/src/examples/org/apache/hama/examples/CosineSimilarityMatrix.java (original)
+++ incubator/hama/trunk/src/examples/org/apache/hama/examples/CosineSimilarityMatrix.java Fri Oct 23 02:48:03 2009
@@ -14,6 +14,8 @@
 import org.apache.hadoop.hbase.util.Bytes;
 import org.apache.hadoop.mapreduce.Job;
 import org.apache.hama.Constants;
+import org.apache.hama.HamaAdmin;
+import org.apache.hama.HamaAdminImpl;
 import org.apache.hama.HamaConfiguration;
 import org.apache.hama.matrix.DenseMatrix;
 import org.apache.hama.matrix.DenseVector;
@@ -74,13 +76,15 @@
 
   private static Job configureJob(HamaConfiguration conf, String[] args)
       throws IOException {
+    HamaAdmin admin = new HamaAdminImpl(conf);
+    
     Job job = new Job(conf, "set MR job test");
-    job.getConfiguration().set("input.matrix", args[0]);
+    job.getConfiguration().set("input.matrix", admin.getPath(args[0]));
 
     Scan scan = new Scan();
     scan.addFamily(Bytes.toBytes(Constants.COLUMN_FAMILY));
 
-    TableMapReduceUtil.initTableMapperJob(args[0], scan,
+    TableMapReduceUtil.initTableMapperJob(admin.getPath(args[0]), scan,
         ComputeSimilarityMapper.class, ImmutableBytesWritable.class, Put.class, job);
     TableMapReduceUtil.initTableReducerJob(args[1], IdentityTableReducer.class,
         job);