GH-5691 CLI for running and storing query explanations

Author: hmottestad

core/common/iterator/src/main/java/org/eclipse/rdf4j/common/iteration/LookAheadIteration.java

@@ -54,6 +54,12 @@ public final boolean hasNext() {
 			return false;
 		}
 
+		if(Thread.currentThread().isInterrupted()) {
+			log.debug("Thread {} is interrupted, closing iteration", Thread.currentThread().getName());
+			close();
+			return false;
+		}
+
 		try {
 			return lookAhead() != null;
 		} catch (NoSuchElementException logged) {

core/sail/lmdb/src/test/java/org/eclipse/rdf4j/sail/lmdb/benchmark/ThemeQueryBenchmark.java

@@ -51,10 +51,10 @@
 import org.openjdk.jmh.runner.options.OptionsBuilder;
 
 @State(Scope.Benchmark)
-@Warmup(iterations = 2, batchSize = 1, timeUnit = TimeUnit.SECONDS, time = 3)
+@Warmup(iterations = 1, batchSize = 1, timeUnit = TimeUnit.SECONDS, time = 30)
 @BenchmarkMode({ Mode.AverageTime })
 @Fork(value = 1, jvmArgs = { "-Xms32G", "-Xmx32G" })
-@Measurement(iterations = 2, batchSize = 1, timeUnit = TimeUnit.MILLISECONDS, time = 100)
+@Measurement(iterations = 1, batchSize = 1, timeUnit = TimeUnit.SECONDS, time = 10)
 @OutputTimeUnit(TimeUnit.MILLISECONDS)
 public class ThemeQueryBenchmark {
 

testsuites/benchmark/src/main/java/org/eclipse/rdf4j/benchmark/plan/QueryPlanSnapshotCli.java

@@ -35,6 +35,7 @@
 import org.eclipse.rdf4j.benchmark.common.plan.QueryPlanSnapshot;
 import org.eclipse.rdf4j.benchmark.rio.util.ThemeDataSetGenerator.Theme;
 import org.eclipse.rdf4j.common.annotation.Experimental;
+import org.eclipse.rdf4j.query.QueryInterruptedException;
 import org.eclipse.rdf4j.query.TupleQuery;
 import org.eclipse.rdf4j.queryrender.sparql.TupleExprIRRenderer;
 import org.eclipse.rdf4j.repository.sail.SailRepositoryConnection;
@@ -1016,10 +1017,17 @@ private QueryExecutionVerification verifyRepeatedExecution(SailRepositoryConnect
 			}
 
 			long startedAt = System.nanoTime();
-			long currentResultCount = prepareTupleQuery(connection, queryText, queryTimeoutSeconds)
-					.evaluate()
-					.stream()
-					.count();
+			long currentResultCount;
+			try {
+				currentResultCount = prepareTupleQuery(connection, queryText, queryTimeoutSeconds)
+						.evaluate()
+						.stream()
+						.count();
+			}catch (QueryInterruptedException interrupted) {
+				softLimitReached = true;
+				break;
+			}
+
 			long runNanos = Math.max(1L, System.nanoTime() - startedAt);
 			elapsedNanos += runNanos;
 			runs++;