commit 46e87503f25c7a3ffa0741d0483590f36afc17cd
author Keith Turner <kturner@apache.org> Fri Sep 25 21:18:33 2020 -0400
committer Keith Turner <kturner@apache.org> Fri Sep 25 21:30:31 2020 -0400
tree 4f23484ffac1526da0740a9f4fed522d16dcbf61
parent b0867a79ab3f380ddbbc641e0f447b512643aa45

presplit table

src/main/java/org/apache/accumulo/testing/performance/tests/GroupCommitPT.java

diff --git a/src/main/java/org/apache/accumulo/testing/performance/tests/GroupCommitPT.java b/src/main/java/org/apache/accumulo/testing/performance/tests/GroupCommitPT.java
index 4614e3c..bea5e0e 100644
--- a/src/main/java/org/apache/accumulo/testing/performance/tests/GroupCommitPT.java
+++ b/src/main/java/org/apache/accumulo/testing/performance/tests/GroupCommitPT.java
@@ -21,11 +21,14 @@
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Random;
+import java.util.SortedSet;
+import java.util.TreeSet;
 
 import org.apache.accumulo.core.client.BatchWriter;
 import org.apache.accumulo.core.client.BatchWriterConfig;
 import org.apache.accumulo.core.client.MutationsRejectedException;
 import org.apache.accumulo.core.client.Scanner;
+import org.apache.accumulo.core.client.admin.NewTableConfiguration;
 import org.apache.accumulo.core.conf.Property;
 import org.apache.accumulo.core.data.Key;
 import org.apache.accumulo.core.data.Mutation;
@@ -35,6 +38,7 @@
 import org.apache.accumulo.testing.performance.PerformanceTest;
 import org.apache.accumulo.testing.performance.Report;
 import org.apache.accumulo.testing.performance.SystemConfiguration;
+import org.apache.hadoop.io.Text;
 
 import com.google.common.base.Preconditions;
 
@@ -169,8 +173,17 @@
 
     Preconditions.checkArgument(NUM_MUTATIONS % numThreads == 0);
 
+    // presplit tablet to allow more concurrency to tablet in memory map updates, so this does not
+    // impeded write ahead log appends.
+    NewTableConfiguration ntc = new NewTableConfiguration();
+    SortedSet<Text> splits = new TreeSet<>();
+    for (int s = 16; s < 256; s += 16) {
+      splits.add(new Text(new byte[] {(byte) s}));
+    }
+    ntc.withSplits(splits);
+
     String tableName = "mutslam";
-    env.getClient().tableOperations().create(tableName);
+    env.getClient().tableOperations().create(tableName, ntc);
 
     // scan just to wait for tablet be online
     Scanner scanner = env.getClient().createScanner(tableName, Authorizations.EMPTY);