svn commit: r1188038 - /mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/RowIdJob.java

[srowen]

Author: srowen
Date: Mon Oct 24 07:29:36 2011
New Revision: 1188038

URL: http://svn.apache.org/viewvc?rev=1188038&view=rev
Log:
MAHOUT-839 call parseArguments() to make sure all args are ready for the job to 
use

Modified:
    
mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/RowIdJob.java

Modified: 
mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/RowIdJob.java
URL: 
http://svn.apache.org/viewvc/mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/RowIdJob.java?rev=1188038&r1=1188037&r2=1188038&view=diff
==============================================================================
--- 
mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/RowIdJob.java
 (original)
+++ 
mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/RowIdJob.java
 Mon Oct 24 07:29:36 2011
@@ -33,15 +33,22 @@ import org.apache.mahout.math.VectorWrit
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.Map;
+
 public class RowIdJob extends AbstractJob {
   private static final Logger log = LoggerFactory.getLogger(RowIdJob.class);
 
   @Override
-  public int run(String[] strings) throws Exception {
+  public int run(String[] args) throws Exception {
 
     addInputOption();
     addOutputOption();
 
+    Map<String,String> parsedArgs = parseArguments(args);
+    if (parsedArgs == null) {
+      return -1;
+    }
+
     Configuration conf = getConf();
     FileSystem fs = FileSystem.get(conf);