accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject git commit: ACCUMULO-2584 use IteratorSettings to push the scan iterator, not a zookeeper setting
Date Wed, 02 Apr 2014 15:04:07 GMT
Repository: accumulo
Updated Branches:
  refs/heads/1.6.0-SNAPSHOT d896bf37d -> 09388f567


ACCUMULO-2584 use IteratorSettings to push the scan iterator, not a zookeeper setting


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/09388f56
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/09388f56
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/09388f56

Branch: refs/heads/1.6.0-SNAPSHOT
Commit: 09388f5671a3979c3c83c5de8f63eb55a3e83fcb
Parents: d896bf3
Author: Eric C. Newton <eric.newton@gmail.com>
Authored: Wed Apr 2 11:02:37 2014 -0400
Committer: Eric C. Newton <eric.newton@gmail.com>
Committed: Wed Apr 2 11:02:37 2014 -0400

----------------------------------------------------------------------
 .../src/test/java/org/apache/accumulo/test/ShellServerIT.java | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/09388f56/test/src/test/java/org/apache/accumulo/test/ShellServerIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/ShellServerIT.java b/test/src/test/java/org/apache/accumulo/test/ShellServerIT.java
index 87288c7..1a0ef5b 100644
--- a/test/src/test/java/org/apache/accumulo/test/ShellServerIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/ShellServerIT.java
@@ -41,6 +41,7 @@ import jline.console.ConsoleReader;
 
 import org.apache.accumulo.core.Constants;
 import org.apache.accumulo.core.client.Connector;
+import org.apache.accumulo.core.client.IteratorSetting;
 import org.apache.accumulo.core.client.Scanner;
 import org.apache.accumulo.core.client.TableNotFoundException;
 import org.apache.accumulo.core.client.admin.TableOperations;
@@ -58,6 +59,7 @@ import org.apache.accumulo.core.util.UtilWaitThread;
 import org.apache.accumulo.core.util.shell.Shell;
 import org.apache.accumulo.test.functional.FunctionalTestUtils;
 import org.apache.accumulo.test.functional.SimpleMacIT;
+import org.apache.accumulo.test.functional.SlowIterator;
 import org.apache.accumulo.tracer.TraceServer;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang.StringUtils;
@@ -994,10 +996,11 @@ public class ShellServerIT extends SimpleMacIT {
     for (int i = 0; i < 6; i++) {
       ts.exec("insert " + i + " cf cq value", true);
     }
-    ts.exec("config -t " + table + " -s table.iterator.scan.slow=30,org.apache.accumulo.test.functional.SlowIterator",
true);
-    ts.exec("config -t " + table + " -s table.iterator.scan.slow.opt.sleepTime=500", true);
     Connector connector = getConnector();
     final Scanner s = connector.createScanner(table, Authorizations.EMPTY);
+    IteratorSetting cfg = new IteratorSetting(30, SlowIterator.class);
+    SlowIterator.setSleepTime(cfg, 500);
+    s.addScanIterator(cfg);
 
     Thread thread = new Thread() {
       @Override


Mime
View raw message