incubator-hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r726666 - in /incubator/hama/trunk/src/java/org/apache/hama: DenseMatrix.java mapred/BlockingMapRed.java
Date Mon, 15 Dec 2008 10:04:23 GMT
Author: edwardyoon
Date: Mon Dec 15 02:04:22 2008
New Revision: 726666

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

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

Modified: incubator/hama/trunk/src/java/org/apache/hama/DenseMatrix.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/DenseMatrix.java?rev=726666&r1=726665&r2=726666&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/DenseMatrix.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/DenseMatrix.java Mon Dec 15 02:04:22 2008
@@ -452,9 +452,14 @@
     int columnSize = (j1 - j0) + 1;
     SubMatrix result = new SubMatrix((i1 - i0) + 1, columnSize);
 
+    byte[][] cols = new byte[columnSize][];
+    for (int j = j0, jj = 0; j <= j1; j++, jj++) {
+      cols[jj] = BytesUtil.getColumnIndex(j);
+    }
+
     RowResult rs = null;
     for (int i = i0, ii = 0; i <= i1; i++, ii++) {
-      rs = table.getRow(BytesUtil.intToBytes(i));
+      rs = table.getRow(BytesUtil.intToBytes(i), cols);
       for (int j = j0, jj = 0; j <= j1; j++, jj++) {
         result.set(ii, jj, rs.get(BytesUtil.getColumnIndex(j)).getValue());
       }

Modified: incubator/hama/trunk/src/java/org/apache/hama/mapred/BlockingMapRed.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/mapred/BlockingMapRed.java?rev=726666&r1=726665&r2=726666&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/mapred/BlockingMapRed.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/mapred/BlockingMapRed.java Mon Dec 15 02:04:22
2008
@@ -65,7 +65,6 @@
    * Abstract Blocking Map/Reduce Class to configure the job.
    */
   public static abstract class BlockingMapRedBase extends MapReduceBase {
-
     protected DenseMatrix matrix;
     
     @Override



Mime
View raw message