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/11/26 05:10:37 UTC
svn commit: r720734 -
/incubator/hama/trunk/src/java/org/apache/hama/DenseMatrix.java
Author: edwardyoon
Date: Tue Nov 25 20:10:37 2008
New Revision: 720734
URL: http://svn.apache.org/viewvc?rev=720734&view=rev
Log: (empty)
Modified:
incubator/hama/trunk/src/java/org/apache/hama/DenseMatrix.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=720734&r1=720733&r2=720734&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/DenseMatrix.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/DenseMatrix.java Tue Nov 25 20:10:37 2008
@@ -398,21 +398,21 @@
public void blocking_mapred(int blockNum) throws IOException {
setBlockPosition(blockNum);
setBlockSize(blockNum);
-
+
JobConf jobConf = new JobConf(config);
jobConf.setJobName("Blocking MR job" + getPath());
-
+
jobConf.setNumMapTasks(config.getNumMapTasks());
jobConf.setNumReduceTasks(config.getNumReduceTasks());
-
+
BlockingMapRed.initJob(getPath(), jobConf);
-
+
JobManager.execute(jobConf);
}
public boolean isBlocked() throws IOException {
- return (table.get(Constants.METADATA, Constants.BLOCK_SIZE) == null) ?
- false : true;
+ return (table.get(Constants.METADATA, Constants.BLOCK_SIZE) == null) ? false
+ : true;
}
public SubMatrix getBlock(int i, int j) throws IOException {
@@ -479,9 +479,10 @@
protected String getBlockKey(int i, int j) {
return i + "," + j;
}
-
+
/**
- * Using a scanner to block a dense matrix.
+ * Using a scanner to block a dense matrix. If the matrix is large, use the
+ * blocking_mapred()
*
* @param blockNum
* @throws IOException