accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject svn commit: r1430011 - /accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java
Date Mon, 07 Jan 2013 21:11:22 GMT
Author: ecn
Date: Mon Jan  7 21:11:22 2013
New Revision: 1430011

URL: http://svn.apache.org/viewvc?rev=1430011&view=rev
Log:
ACCUMULO-745 modify TestIngest to respect BatchWriter cli options

Modified:
    accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java

Modified: accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java
URL: http://svn.apache.org/viewvc/accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java?rev=1430011&r1=1430010&r2=1430011&view=diff
==============================================================================
--- accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java (original)
+++ accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java Mon
Jan  7 21:11:22 2013
@@ -20,6 +20,7 @@ import java.util.Random;
 import java.util.TreeSet;
 
 import org.apache.accumulo.cloudtrace.instrument.Trace;
+import org.apache.accumulo.core.cli.BatchWriterOpts;
 import org.apache.accumulo.core.client.BatchWriter;
 import org.apache.accumulo.core.client.BatchWriterConfig;
 import org.apache.accumulo.core.client.Connector;
@@ -171,7 +172,8 @@ public class TestIngest {
   public static void main(String[] args) throws Exception {
     
     Opts opts = new Opts();
-    opts.parseArgs(TestIngest.class.getName(), args);
+    BatchWriterOpts bwOpts = new BatchWriterOpts();
+    opts.parseArgs(TestIngest.class.getName(), args, bwOpts);
     opts.getInstance().setConfiguration(ServerConfiguration.getSiteConfiguration());
 
     createTable(opts);
@@ -208,7 +210,7 @@ public class TestIngest {
             AccumuloConfiguration.getDefaultConfiguration());
         writer.startDefaultLocalityGroup();
       } else {
-        bw = connector.createBatchWriter(opts.getTableName(), new BatchWriterConfig());
+        bw = connector.createBatchWriter(opts.getTableName(), bwOpts.getBatchWriterConfig());
       }
       connector.securityOperations().changeUserAuthorizations(opts.user, AUTHS);
       Text labBA = new Text(opts.columnVisibility.getExpression());



Mime
View raw message