accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject svn commit: r1445221 - /accumulo/trunk/examples/instamo/src/main/java/org/apache/accumulo/instamo/MapReduceExample.java
Date Tue, 12 Feb 2013 16:02:57 GMT
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));



Mime
View raw message