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 2012/12/10 10:42:46 UTC
svn commit: r1419294 -
/hama/trunk/examples/src/main/java/org/apache/hama/examples/util/SymmetricMatrixGen.java
Author: edwardyoon
Date: Mon Dec 10 09:42:45 2012
New Revision: 1419294
URL: http://svn.apache.org/viewvc?rev=1419294&view=rev
Log:
Fix typos.
Modified:
hama/trunk/examples/src/main/java/org/apache/hama/examples/util/SymmetricMatrixGen.java
Modified: hama/trunk/examples/src/main/java/org/apache/hama/examples/util/SymmetricMatrixGen.java
URL: http://svn.apache.org/viewvc/hama/trunk/examples/src/main/java/org/apache/hama/examples/util/SymmetricMatrixGen.java?rev=1419294&r1=1419293&r2=1419294&view=diff
==============================================================================
--- hama/trunk/examples/src/main/java/org/apache/hama/examples/util/SymmetricMatrixGen.java (original)
+++ hama/trunk/examples/src/main/java/org/apache/hama/examples/util/SymmetricMatrixGen.java Mon Dec 10 09:42:45 2012
@@ -44,14 +44,14 @@ import org.apache.hama.examples.CombineE
public class SymmetricMatrixGen {
protected static Log LOG = LogFactory.getLog(SymmetricMatrixGen.class);
- private static String NUM_OF_VERTICES = "size.of.matrix";
+ private static String SIZE_OF_MATRIX = "size.of.matrix";
private static String DENSITY = "density.of.matrix";
public static class SymmetricMatrixGenBSP extends
BSP<NullWritable, NullWritable, Text, TextArrayWritable, Text> {
private Configuration conf;
- private int numberN;
+ private int sizeN;
private int density;
private Map<Integer, HashSet<Integer>> list = new HashMap<Integer, HashSet<Integer>>();
@@ -59,7 +59,7 @@ public class SymmetricMatrixGen {
public void setup(
BSPPeer<NullWritable, NullWritable, Text, TextArrayWritable, Text> peer) {
this.conf = peer.getConfiguration();
- numberN = conf.getInt(NUM_OF_VERTICES, 10);
+ sizeN = conf.getInt(SIZE_OF_MATRIX, 10);
density = conf.getInt(DENSITY, 1);
}
@@ -67,11 +67,11 @@ public class SymmetricMatrixGen {
public void bsp(
BSPPeer<NullWritable, NullWritable, Text, TextArrayWritable, Text> peer)
throws IOException, SyncException, InterruptedException {
- int interval = numberN / peer.getNumPeers();
+ int interval = sizeN / peer.getNumPeers();
int startID = peer.getPeerIndex() * interval;
int endID;
if (peer.getPeerIndex() == peer.getNumPeers() - 1)
- endID = numberN;
+ endID = sizeN;
else
endID = startID + interval;
@@ -125,14 +125,14 @@ public class SymmetricMatrixGen {
IOException, ClassNotFoundException {
if (args.length < 4) {
System.out
- .println("Usage: <number n> <1/x density> <output path> <number of tasks>");
+ .println("Usage: <size n> <1/x density> <output path> <number of tasks>");
System.exit(1);
}
// BSP job configuration
HamaConfiguration conf = new HamaConfiguration();
- conf.setInt(NUM_OF_VERTICES, Integer.parseInt(args[0]));
+ conf.setInt(SIZE_OF_MATRIX, Integer.parseInt(args[0]));
conf.setInt(DENSITY, Integer.parseInt(args[1]));
BSPJob bsp = new BSPJob(conf, CombineExample.class);