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 2008/12/15 11:04:23 UTC
svn commit: r726666 - in /incubator/hama/trunk/src/java/org/apache/hama:
DenseMatrix.java mapred/BlockingMapRed.java
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