svn commit: r1430011 - /accumulo/trunk/server/src/main/java/org/apache/accumulo/server/test/TestIngest.java

[ecn]

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());