This is an automated email from the ASF dual-hosted git repository.
philo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new ce767062ad [GLUTEN-10959][FLINK] Support function `decimal_notequalto`
(#10960)
ce767062ad is described below
commit ce767062ad922fd59b7cb34d2abcebf11c67a134
Author: xinghuayu007 <[email protected]>
AuthorDate: Wed Nov 5 17:05:24 2025 +0800
[GLUTEN-10959][FLINK] Support function `decimal_notequalto` (#10960)
---
.../gluten/rexnode/functions/RexCallConverterFactory.java | 4 ++++
.../table/runtime/stream/custom/ScalarFunctionsTest.java | 12 ++++++++++++
2 files changed, 16 insertions(+)
diff --git
a/gluten-flink/planner/src/main/java/org/apache/gluten/rexnode/functions/RexCallConverterFactory.java
b/gluten-flink/planner/src/main/java/org/apache/gluten/rexnode/functions/RexCallConverterFactory.java
index 03c20b63a1..1353ff8200 100644
---
a/gluten-flink/planner/src/main/java/org/apache/gluten/rexnode/functions/RexCallConverterFactory.java
+++
b/gluten-flink/planner/src/main/java/org/apache/gluten/rexnode/functions/RexCallConverterFactory.java
@@ -58,6 +58,10 @@ public class RexCallConverterFactory {
() -> new BasicArithmeticOperatorRexCallConverter("equalto"),
() -> new StringCompareRexCallConverter("equalto"),
() -> new StringNumberCompareRexCallConverter("equalto"))),
+ Map.entry(
+ "<>",
+ Arrays.asList(
+ () -> new
DecimalArithmeticOperatorRexCallConverters("decimal_notequalto"))),
Map.entry(
"/", Arrays.asList(() -> new
DecimalArithmeticOperatorRexCallConverters("divide"))),
Map.entry(
diff --git
a/gluten-flink/ut/src/test/java/org/apache/gluten/table/runtime/stream/custom/ScalarFunctionsTest.java
b/gluten-flink/ut/src/test/java/org/apache/gluten/table/runtime/stream/custom/ScalarFunctionsTest.java
index 51f1b42e85..68d04f53d5 100644
---
a/gluten-flink/ut/src/test/java/org/apache/gluten/table/runtime/stream/custom/ScalarFunctionsTest.java
+++
b/gluten-flink/ut/src/test/java/org/apache/gluten/table/runtime/stream/custom/ScalarFunctionsTest.java
@@ -294,4 +294,16 @@ class ScalarFunctionsTest extends GlutenStreamingTestBase {
"+I[1, 2024-12-31 12:12:12, 2024-12-31 20:12:12]",
"+I[2, 2025-02-28 12:12:12, 2024-02-28 20:12:12]"));
}
+
+ @Test
+ void testNotEqual() {
+ List<Row> rows =
+ Arrays.asList(
+ Row.of(new BigDecimal("1.2"), 1L, "2", "1"),
+ Row.of(new BigDecimal("2.2"), 2L, "2", "2"),
+ Row.of(new BigDecimal("3.2"), 3L, "2", "1"));
+ createSimpleBoundedValuesTable("tblLess", "a decimal(4,2), b bigint, c
string, d string", rows);
+ String query = "select a <> 2.20 as x from tblLess where a > 0";
+ runAndCheck(query, Arrays.asList("+I[true]", "+I[false]", "+I[true]"));
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
