Removed threadThrottleFactor related methods. In the next release, we'll have autoscaling. It has similar functionality of threadThrottleFactor. We are removing this, otherwise it will confuse users.

Author: lling

marklogic-client-api/src/main/java/com/marklogic/client/datamovement/QueryBatcher.java

@@ -310,7 +310,7 @@ public interface QueryBatcher extends Batcher {
    *                             0 explicitly uses the maximum number of threads
    * @return this instance for method chaining
    */
-  public QueryBatcher withBatchSize(int docBatchSize, int docToUriBatchRatio, int threadThrottleFactor);
+  //public QueryBatcher withBatchSize(int docBatchSize, int docToUriBatchRatio, int threadThrottleFactor);
 
   /**
    * Returns docToUriBatchRatio set to the QueryBatcher
@@ -322,7 +322,7 @@ public interface QueryBatcher extends Batcher {
    * Returns threadThrottleFactor set to the QueryBatcher
    * @return threadThrottleFactor
    */
-  public int getThreadThrottleFactor();
+  //public int getThreadThrottleFactor();
 
   /**
    * Returns defaultDocBatchSize, which is calculated according to server status

marklogic-client-api/src/main/java/com/marklogic/client/datamovement/impl/QueryBatcherImpl.java

@@ -344,7 +344,7 @@ public QueryBatcher withBatchSize(int docBatchSize, int docToUriBatchRatio) {
     return this;
   }
 
-  @Override
+/*  @Override
   public QueryBatcher withBatchSize(int docBatchSize, int docToUriBatchRatio, int threadThrottleFactor) {
     if (threadThrottleFactor < 0 || threadThrottleFactor > this.maxDocToUriBatchRatio) {
       throw new IllegalArgumentException("threadThrottleFactor is less than 0 or " +
@@ -356,14 +356,14 @@ public QueryBatcher withBatchSize(int docBatchSize, int docToUriBatchRatio, int
     withBatchSize(docBatchSize, docToUriBatchRatio);
     this.threadThrottleFactor = threadThrottleFactor;
     return this;
-  }
+  }*/
 
   @Override
   public int getDocToUriBatchRatio() {
     return this.docToUriBatchRatio;
   }
 
-  @Override
+//  @Override
   public int getThreadThrottleFactor() {
     return this.threadThrottleFactor;
   }

marklogic-client-api/src/test/java/com/marklogic/client/test/datamovement/ConcurrencyTest.java

@@ -55,7 +55,7 @@ public void ConcurrencyTest() {
         int batchSize = 20;
         int docToUriBatchRatio = 5;
         int totalCount = 1000;
-        int threadThrottleFactor = 4;
+        //int threadThrottleFactor = 4;
 
         DocumentMetadataHandle documentMetadata = new DocumentMetadataHandle().withCollections("ConcurrencyTest");
         WriteBatcher batcher = moveMgr.newWriteBatcher().withDefaultMetadata(documentMetadata);
@@ -93,7 +93,7 @@ public void ConcurrencyTest() {
 
         assertTrue("Output list does not contain all number of outputs", outputUris.size() == totalCount);
 
-        QueryBatcher queryBatcherAfter = dmManager.newQueryBatcher(new StructuredQueryBuilder().collection("ConcurrencyTest"));
+/*        QueryBatcher queryBatcherAfter = dmManager.newQueryBatcher(new StructuredQueryBuilder().collection("ConcurrencyTest"));
         AtomicInteger minAfter = new AtomicInteger(Integer.MAX_VALUE);
         AtomicInteger maxAfter = new AtomicInteger(0);
         queryBatcherAfter.withBatchSize(batchSize, docToUriBatchRatio, threadThrottleFactor)
@@ -113,10 +113,10 @@ public void ConcurrencyTest() {
 
         dmManager.startJob(queryBatcherAfter);
         queryBatcherAfter.awaitCompletion();
-        dmManager.stopJob(queryBatcherAfter);
+        dmManager.stopJob(queryBatcherAfter);*/
 
         assertTrue(max.get() <= forest_count * docToUriBatchRatio);
-        assertTrue(maxAfter.get() <= forest_count * (docToUriBatchRatio - threadThrottleFactor));
+        //assertTrue(maxAfter.get() <= forest_count * (docToUriBatchRatio - threadThrottleFactor));
     }
 
     static void changeAssignmentPolicy(String value) throws IOException {