svn commit: r1445221 - /accumulo/trunk/examples/instamo/src/main/java/org/apache/accumulo/instamo/MapReduceExample.java

[kturner]

Author: kturner
Date: Tue Feb 12 16:02:56 2013
New Revision: 1445221

URL: http://svn.apache.org/r1445221
Log:
ACCUMULO-745 updated example to use new continuous ingest options

Modified:
    
accumulo/trunk/examples/instamo/src/main/java/org/apache/accumulo/instamo/MapReduceExample.java

Modified: 
accumulo/trunk/examples/instamo/src/main/java/org/apache/accumulo/instamo/MapReduceExample.java
URL: 
http://svn.apache.org/viewvc/accumulo/trunk/examples/instamo/src/main/java/org/apache/accumulo/instamo/MapReduceExample.java?rev=1445221&r1=1445220&r2=1445221&view=diff
==============================================================================
--- 
accumulo/trunk/examples/instamo/src/main/java/org/apache/accumulo/instamo/MapReduceExample.java
 (original)
+++ 
accumulo/trunk/examples/instamo/src/main/java/org/apache/accumulo/instamo/MapReduceExample.java
 Tue Feb 12 16:02:56 2013
@@ -19,9 +19,9 @@ package org.apache.accumulo.instamo;
 import java.io.File;
 import java.util.UUID;
 
+import org.apache.accumulo.test.MiniAccumuloCluster;
 import org.apache.accumulo.test.continuous.ContinuousIngest;
 import org.apache.accumulo.test.continuous.ContinuousVerify;
-import org.apache.accumulo.test.MiniAccumuloCluster;
 import org.apache.commons.io.FileUtils;
 
 /**
@@ -32,15 +32,15 @@ public class MapReduceExample {
   public static void run(String instanceName, String zookeepers, String 
rootPassword, String args[]) throws Exception {
     
     // run continuous ingest to create data. This is not a map reduce job
-    ContinuousIngest.main(new String[] {instanceName, zookeepers, "root", 
rootPassword, "ci", "5000000", "0", Long.MAX_VALUE + "", "1000", "1000", 
"1000000",
-        "60000", "2", "false"});
+    ContinuousIngest.main(new String[] {"-i", instanceName, "-z", zookeepers, 
"-u", "root", "-p", rootPassword, "--table", "ci", "--num", "5000000",
+        "--batchMemory", "1000000"});
     
     String outputDir = FileUtils.getTempDirectoryPath() + File.separator + 
"ci_verify" + UUID.randomUUID().toString();
     
     try {
       // run verify map reduce job locally. This jobs looks for holes in the 
linked list create by continuous ingest
-      ContinuousVerify.main(new String[] {"-D", "mapred.job.tracker=local", 
"-D", "fs.default.name=file:///", instanceName, zookeepers, "root", 
rootPassword,
-          "ci", outputDir, "4", "1", "false"});
+      ContinuousVerify.main(new String[] {"-D", "mapred.job.tracker=local", 
"-D", "fs.default.name=file:///", "-i", instanceName, "-z", zookeepers, "-u",
+          "root", "-p", rootPassword, "--table", "ci", "--output", outputDir, 
"--maxMappers", "4", "--reducers", "1"});
     } finally {
       // delete output dir of mapreduce job
       FileUtils.deleteQuietly(new File(outputDir));