Adding big5 coalesce queries (#4127)

aalva500-prog · aaarone90 · web-flow · commit ff3dfdc8556e · 2025-09-02T16:15:44.000-07:00
* Adding big5 coalesce queries

Signed-off-by: Aaron Alvarez &lt;aaarone@amazon.com&gt;

* Adding queries to PPLBig5IT

Signed-off-by: Aaron Alvarez &lt;aaarone@amazon.com&gt;

* Fixing queries and test files

Signed-off-by: Aaron Alvarez &lt;aaarone@amazon.com&gt;

* Updating queries

Signed-off-by: Aaron Alvarez &lt;aaarone@amazon.com&gt;

---------

Signed-off-by: Aaron Alvarez &lt;aaarone@amazon.com&gt;
Co-authored-by: Aaron Alvarez &lt;aaarone@amazon.com&gt;
diff --git a/integ-test/src/test/java/org/opensearch/sql/calcite/big5/CalcitePPLBig5IT.java b/integ-test/src/test/java/org/opensearch/sql/calcite/big5/CalcitePPLBig5IT.java
@@ -5,7 +5,9 @@
 
 package org.opensearch.sql.calcite.big5;
 
+import java.io.IOException;
 import org.junit.FixMethodOrder;
+import org.junit.Test;
 import org.junit.runners.MethodSorters;
 
 @FixMethodOrder(MethodSorters.JVM)
@@ -16,4 +18,10 @@ public void init() throws Exception {
     super.init();
     enableCalcite();
   }
+
+  @Test
+  public void coalesce_nonexistent_field_fallback() throws IOException {
+    String ppl = sanitize(loadFromFile("big5/queries/coalesce_nonexistent_field_fallback.ppl"));
+    timing(summary, "coalesce_nonexistent_field_fallback", ppl);
+  }
 }
diff --git a/integ-test/src/test/java/org/opensearch/sql/calcite/big5/PPLBig5IT.java b/integ-test/src/test/java/org/opensearch/sql/calcite/big5/PPLBig5IT.java
@@ -17,7 +17,7 @@
 
 @FixMethodOrder(MethodSorters.JVM)
 public class PPLBig5IT extends PPLIntegTestCase {
-  private static final MapBuilder<String, Long> summary = MapBuilder.newMapBuilder();
+  protected static final MapBuilder<String, Long> summary = MapBuilder.newMapBuilder();
 
   @Override
   public void init() throws Exception {
diff --git a/integ-test/src/test/resources/big5/queries/coalesce_nonexistent_field_fallback.ppl b/integ-test/src/test/resources/big5/queries/coalesce_nonexistent_field_fallback.ppl
@@ -0,0 +1,3 @@
+source = big5
+| eval result = coalesce(dummy_field, `host.name`, `metrics.size`, 'unknown')
+| head 10

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+source = big5`
	`2`	+\| eval result = coalesce(dummy_field, `host.name`, `metrics.size`, 'unknown')
	`3`	`+\| head 10`