(calcite) branch main updated: Add IS_UNKNOWN operator test in Arrow Adapter

[mbudiu]

This is an automated email from the ASF dual-hosted git repository.

mbudiu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/calcite.git


The following commit(s) were added to refs/heads/main by this push:
     new 4ba1e1d211 Add IS_UNKNOWN operator test in Arrow Adapter
4ba1e1d211 is described below

commit 4ba1e1d2113857382fea43eacb96830cae306f70
Author: Cancai Cai <2356672...@qq.com>
AuthorDate: Sat Nov 16 22:47:38 2024 +0800

    Add IS_UNKNOWN operator test in Arrow Adapter
---
 .../apache/calcite/adapter/arrow/ArrowAdapterTest.java | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git 
a/arrow/src/test/java/org/apache/calcite/adapter/arrow/ArrowAdapterTest.java 
b/arrow/src/test/java/org/apache/calcite/adapter/arrow/ArrowAdapterTest.java
index 2e766c0384..9e60bca2a4 100644
--- a/arrow/src/test/java/org/apache/calcite/adapter/arrow/ArrowAdapterTest.java
+++ b/arrow/src/test/java/org/apache/calcite/adapter/arrow/ArrowAdapterTest.java
@@ -943,4 +943,22 @@ class ArrowAdapterTest {
         .returns(result)
         .explainContains(plan);
   }
+
+  @Test void testArrowProjectFieldsWithIsUnknownFilter() {
+    String sql = "select \"booleanField\"\n"
+        + "from arrowdatatype\n"
+        + "where \"booleanField\" is unknown";
+    String plan = "PLAN=ArrowToEnumerableConverter\n"
+        + "  ArrowProject(booleanField=[$7])\n"
+        + "    ArrowFilter(condition=[IS NULL($7)])\n"
+        + "      ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 
2, 3, 4, 5, 6, 7, 8, 9]])\n\n";
+    String result = "booleanField=null\n";
+
+    CalciteAssert.that()
+        .with(arrow)
+        .query(sql)
+        .limit(1)
+        .returns(result)
+        .explainContains(plan);
+  }
 }