Restore workloads

Author: bgprudhomme

core/sail/memory/src/test/java/org/eclipse/rdf4j/sail/memory/benchmark/ConcurrentQueryBenchmark.java

@@ -88,7 +88,7 @@ public void tearDown() throws Exception {
 	public void hasStatement(Blackhole blackhole) throws Exception {
 		threads(numThreads, () -> {
 			try (SailRepositoryConnection connection = repository.getConnection()) {
-				for (int i = 0; i < 50; i++) {
+				for (int i = 0; i < 100; i++) {
 					boolean b = connection.hasStatement(null, null, null, true);
 					blackhole.consume(b);
 				}
@@ -100,7 +100,7 @@ public void hasStatement(Blackhole blackhole) throws Exception {
 	public void hasStatementSharedConnection(Blackhole blackhole) throws Exception {
 		try (SailRepositoryConnection connection = repository.getConnection()) {
 			threads(numThreads, () -> {
-				for (int i = 0; i < 50; i++) {
+				for (int i = 0; i < 100; i++) {
 					boolean b = connection.hasStatement(null, null, null, true);
 					blackhole.consume(b);
 				}
@@ -112,7 +112,7 @@ public void hasStatementSharedConnection(Blackhole blackhole) throws Exception {
 	public void getNamespaces(Blackhole blackhole) throws Exception {
 		threads(numThreads, () -> {
 			try (SailRepositoryConnection connection = repository.getConnection()) {
-				for (int i = 0; i < 50; i++) {
+				for (int i = 0; i < 100; i++) {
 					blackhole.consume(connection.getNamespaces().stream().count());
 				}
 			}
@@ -123,7 +123,7 @@ public void getNamespaces(Blackhole blackhole) throws Exception {
 	public void getNamespacesSharedConnection(Blackhole blackhole) throws Exception {
 		try (SailRepositoryConnection connection = repository.getConnection()) {
 			threads(numThreads, () -> {
-				for (int i = 0; i < 50; i++) {
+				for (int i = 0; i < 100; i++) {
 					blackhole.consume(connection.getNamespaces().stream().count());
 				}
 			});

core/sail/memory/src/test/java/org/eclipse/rdf4j/sail/memory/benchmark/MemValueFactoryConcurrentBenchmark.java

@@ -66,7 +66,7 @@ public class MemValueFactoryConcurrentBenchmark extends BaseConcurrentBenchmark
 	@Param({ "10", "50", "100", "500", "1000", "5000" })
 	public int numThreads;
 
-	public static final int BUCKET_SIZE = 5000;
+	public static final int BUCKET_SIZE = 10000;
 	private SailRepository repository;
 	private List<List<Value>> values;
 

core/sail/memory/src/test/java/org/eclipse/rdf4j/sail/memory/benchmark/ParallelMixedReadWriteBenchmark.java

@@ -258,7 +258,7 @@ private ArrayList<Runnable> getMixedWorkload(Blackhole blackhole, CountDownLatch
 
 		for (int i = 0; i < 20 * workloadSize; i++) {
 			list.add(getRunnable(startSignal, connection, isolationLevel, (localConnection) -> {
-				for (int j = 0; j < 25; j++) {
+				for (int j = 0; j < 100; j++) {
 					localConnection.add(Values.bnode(), RDFS.LABEL, Values.literal(j),
 							Values.iri("http://example.com/g1"));
 				}

core/sail/memory/src/test/java/org/eclipse/rdf4j/sail/memory/model/MemStatementListTestIT.java

@@ -109,7 +109,7 @@ public static void beforeAll() throws IOException {
 					statements = stream
 							.map(s -> ((MemStatement) s))
 							.sorted(Comparator.comparing(Object::toString))
-							.limit(5000)
+							.limit(10000)
 							.collect(Collectors.toList());
 				}
 				connection.commit();