bump calcite

linkedin · Oct 30, 2024 · bc25437 · bc25437
1 parent a7b8505
commit bc25437
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 20 deletions.
diff --git a/coral-spark/src/test/java/com/linkedin/coral/spark/CoralSparkTest.java b/coral-spark/src/test/java/com/linkedin/coral/spark/CoralSparkTest.java
@@ -724,25 +724,25 @@ public void testReflectFunctionReturnType() {
     assertEquals(createCoralSpark(relNode).getSparkSql(), targetSql);
   }
 
-  //  @Test
-  //  public void testJavaMethodFunction() {
-  //    RelNode relNode = TestUtils.toRelNode("SELECT java_method('java.lang.String', 'valueOf', 1) FROM default.complex");
-  //    String targetSql = "SELECT reflect('java.lang.String', 'valueOf', 1)\n" + "FROM default.complex complex";
-  //    assertEquals(createCoralSpark(relNode).getSparkSql(), targetSql);
-  //  }
-  //
-  //  @Test
-  //  public void testJavaMethodFunctionReturnType() {
-  //    RelNode relNode =
-  //        TestUtils.toRelNode("SELECT java_method('java.lang.String', 'valueOf', 1) + 1 FROM default.complex");
-  //    String targetSql =
-  //        "SELECT CAST(reflect('java.lang.String', 'valueOf', 1) AS INTEGER) + 1\n" + "FROM default.complex complex";
-  //    assertEquals(createCoralSpark(relNode).getSparkSql(), targetSql);
-  //
-  //    relNode = TestUtils.toRelNode("SELECT java_method('java.lang.String', 'valueOf', 1) || 'a' FROM default.complex");
-  //    targetSql = "SELECT concat(reflect('java.lang.String', 'valueOf', 1), 'a')\n" + "FROM default.complex complex";
-  //    assertEquals(createCoralSpark(relNode).getSparkSql(), targetSql);
-  //  }
+    @Test
+    public void testJavaMethodFunction() {
+      RelNode relNode = TestUtils.toRelNode("SELECT java_method('java.lang.String', 'valueOf', 1) FROM default.complex");
+      String targetSql = "SELECT reflect('java.lang.String', 'valueOf', 1)\n" + "FROM default.complex complex";
+      assertEquals(createCoralSpark(relNode).getSparkSql(), targetSql);
+    }
+
+    @Test
+    public void testJavaMethodFunctionReturnType() {
+      RelNode relNode =
+          TestUtils.toRelNode("SELECT java_method('java.lang.String', 'valueOf', 1) + 1 FROM default.complex");
+      String targetSql =
+          "SELECT CAST(reflect('java.lang.String', 'valueOf', 1) AS INTEGER) + 1\n" + "FROM default.complex complex";
+      assertEquals(createCoralSpark(relNode).getSparkSql(), targetSql);
+
+      relNode = TestUtils.toRelNode("SELECT java_method('java.lang.String', 'valueOf', 1) || 'a' FROM default.complex");
+      targetSql = "SELECT concat(reflect('java.lang.String', 'valueOf', 1), 'a')\n" + "FROM default.complex complex";
+      assertEquals(createCoralSpark(relNode).getSparkSql(), targetSql);
+    }
 
   @Test
   public void testNegationOperator() {

diff --git a/gradle/dependencies.gradle b/gradle/dependencies.gradle
@@ -9,7 +9,7 @@ def versions = [
   'jetbrains': '16.0.2',
   'jline': '0.9.94',
   'kryo': '2.22',
-  'linkedin-calcite-core': '1.21.0.262',
+  'linkedin-calcite-core': '1.21.0.264',
   'pig': '0.15.0',
   'spark': '2.4.0',
   'spark3': '3.1.1',