perf(benchmarks): Add SQL queries to UnifiedQueryBenchmark

Add language (PPL/SQL) and queryPattern param dimensions for
side-by-side comparison of equivalent queries across both languages.
Remove separate UnifiedSqlQueryBenchmark in favor of unified class.

Signed-off-by: Chen Dai <daichen@amazon.com>

Author: dai-chen

benchmarks/src/jmh/java/org/opensearch/sql/api/UnifiedQueryBenchmark.java

@@ -6,6 +6,7 @@
 package org.opensearch.sql.api;
 
 import java.sql.PreparedStatement;
+import java.util.Map;
 import java.util.concurrent.TimeUnit;
 import org.apache.calcite.rel.RelNode;
 import org.apache.calcite.sql.dialect.SparkSqlDialect;
@@ -24,10 +25,12 @@
 import org.openjdk.jmh.annotations.Warmup;
 import org.opensearch.sql.api.compiler.UnifiedQueryCompiler;
 import org.opensearch.sql.api.transpiler.UnifiedQueryTranspiler;
+import org.opensearch.sql.executor.QueryType;
 
 /**
- * JMH benchmark for measuring the overhead of unified query API components when processing queries.
- * This provides baseline metrics and guidance for API consumers during integration.
+ * JMH benchmark for measuring the overhead of unified query API components when processing PPL and
+ * SQL queries. The {@code language} and {@code queryPattern} parameters produce a cross-product,
+ * enabling side-by-side comparison of equivalent queries across both languages.
  */
 @Warmup(iterations = 2, time = 1)
 @Measurement(iterations = 5, time = 1)
@@ -37,25 +40,69 @@
 @Fork(value = 1)
 public class UnifiedQueryBenchmark extends UnifiedQueryTestBase {
 
-  /** Common query patterns for benchmarking. */
-  @Param({
-    "source = catalog.employees",
-    "source = catalog.employees | where age > 30",
-    "source = catalog.employees | stats count() by department",
-    "source = catalog.employees | sort - age",
-    "source = catalog.employees | where age > 25 | stats avg(age) by department | sort - department"
-  })
-  private String query;
+  private static final Map<String, String> PPL_QUERIES =
+      Map.of(
+          "scan", "source = catalog.employees",
+          "filter", "source = catalog.employees | where age > 30",
+          "aggregate", "source = catalog.employees | stats count() by department",
+          "sort", "source = catalog.employees | sort - age",
+          "complex",
+              """
+              source = catalog.employees \
+              | where age > 25 \
+              | stats avg(age) by department \
+              | sort - department\
+              """);
 
-  /** Transpiler for converting logical plans to SQL strings. */
-  private UnifiedQueryTranspiler transpiler;
+  private static final Map<String, String> SQL_QUERIES =
+      Map.of(
+          "scan", "SELECT * FROM catalog.employees",
+          "filter",
+              """
+              SELECT *
+              FROM catalog.employees
+              WHERE age > 30\
+              """,
+          "aggregate",
+              """
+              SELECT department, count(*)
+              FROM catalog.employees
+              GROUP BY department\
+              """,
+          "sort",
+              """
+              SELECT *
+              FROM catalog.employees
+              ORDER BY age DESC\
+              """,
+          "complex",
+              """
+              SELECT department, avg(age)
+              FROM catalog.employees
+              WHERE age > 25
+              GROUP BY department
+              ORDER BY department\
+              """);
+
+  @Param({"PPL", "SQL"})
+  private String language;
+
+  @Param({"scan", "filter", "aggregate", "sort", "complex"})
+  private String queryPattern;
 
-  /** Compiler for converting logical plans to executable statements. */
+  private String query;
+  private UnifiedQueryTranspiler transpiler;
   private UnifiedQueryCompiler compiler;
 
+  @Override
+  protected QueryType queryType() {
+    return QueryType.valueOf(language);
+  }
+
   @Setup(Level.Trial)
   public void setUpBenchmark() {
     super.setUp();
+    query = (language.equals("PPL") ? PPL_QUERIES : SQL_QUERIES).get(queryPattern);
     transpiler = UnifiedQueryTranspiler.builder().dialect(SparkSqlDialect.DEFAULT).build();
     compiler = new UnifiedQueryCompiler(context);
   }