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/19 11:07:52 UTC
svn commit: r727991 -
/incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java
Author: edwardyoon
Date: Fri Dec 19 02:07:52 2008
New Revision: 727991
URL: http://svn.apache.org/viewvc?rev=727991&view=rev
Log:
Rollback. Unrelated codes are committed.
Modified:
incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java
Modified: incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java?rev=727991&r1=727990&r2=727991&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/algebra/BlockCyclicMultiplyMap.java Fri Dec 19 02:07:52 2008
@@ -21,9 +21,6 @@
import java.io.IOException;
-import org.apache.hadoop.hbase.client.HTable;
-import org.apache.hadoop.hbase.client.Scanner;
-import org.apache.hadoop.hbase.io.RowResult;
import org.apache.hadoop.mapred.FileInputFormat;
import org.apache.hadoop.mapred.JobConf;
import org.apache.hadoop.mapred.MapReduceBase;
@@ -75,14 +72,6 @@
int blockSize = matrix_b.getBlockSize();
SubMatrix a = value.get();
- HTable table = matrix_b.getHTable();
- Scanner scan = table.getScanner(new String[] {Constants.BLOCK});
-
- for(RowResult row : scan) {
- BlockID segment = new BlockID(row.getRow());
- LOG.info(segment.getRow() + ", " + segment.getColumn());
- }
-
for (int j = 0; j < blockSize; j++) {
SubMatrix b = matrix_b.getBlock(key.getColumn(), j);
SubMatrix c = a.mult(b);