svn commit: r731901 - /incubator/hama/trunk/src/java/org/apache/hama/mapred/RandomMatrixMap.java

[ed...@apache.org]

Author: edwardyoon
Date: Tue Jan  6 02:03:23 2009
New Revision: 731901

URL: http://svn.apache.org/viewvc?rev=731901&view=rev
Log: (empty)

Modified:
    incubator/hama/trunk/src/java/org/apache/hama/mapred/RandomMatrixMap.java

Modified: incubator/hama/trunk/src/java/org/apache/hama/mapred/RandomMatrixMap.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/mapred/RandomMatrixMap.java?rev=731901&r1=731900&r2=731901&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/mapred/RandomMatrixMap.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/mapred/RandomMatrixMap.java Tue Jan  6 02:03:23 2009
@@ -21,6 +21,7 @@
 
 import java.io.IOException;
 
+import org.apache.hadoop.hbase.client.HTable;
 import org.apache.hadoop.io.BooleanWritable;
 import org.apache.hadoop.io.IntWritable;
 import org.apache.hadoop.io.LongWritable;
@@ -29,8 +30,6 @@
 import org.apache.hadoop.mapred.Mapper;
 import org.apache.hadoop.mapred.OutputCollector;
 import org.apache.hadoop.mapred.Reporter;
-import org.apache.hama.DenseMatrix;
-import org.apache.hama.HamaConfiguration;
 import org.apache.hama.io.VectorUpdate;
 import org.apache.hama.util.RandomVariable;
 import org.apache.log4j.Logger;
@@ -41,27 +40,26 @@
 public class RandomMatrixMap extends MapReduceBase implements
     Mapper<IntWritable, IntWritable, BooleanWritable, LongWritable> {
   static final Logger LOG = Logger.getLogger(RandomMatrixMap.class);
-  protected DenseMatrix matrix;
+  protected HTable table;
   protected int column;
-  protected VectorUpdate batchUpdate;
   
   @Override
   public void map(IntWritable key, IntWritable value,
       OutputCollector<BooleanWritable, LongWritable> output, Reporter report)
       throws IOException {
     for (int i = key.get(); i <= value.get(); i++) {
-      batchUpdate = new VectorUpdate(i);
+      VectorUpdate batchUpdate = new VectorUpdate(i);
       for (int j = 0; j < column; j++) {
         batchUpdate.put(j, RandomVariable.rand());
       }
-      matrix.getHTable().commit(batchUpdate.getBatchUpdate());
+      table.commit(batchUpdate.getBatchUpdate());
     }
   }
 
   public void configure(JobConf job) {
     try {
       column = Integer.parseInt(job.get("matrix.column"));
-      matrix = new DenseMatrix(new HamaConfiguration(), job.get("matrix.path"));
+      table = new HTable(job.get("matrix.path"));
     } catch (IOException e) {
       e.printStackTrace();
     }