From 00c8bd1630171108affa4718a35c2b9447546418 Mon Sep 17 00:00:00 2001 From: panmingyi Date: Thu, 17 Jul 2025 16:59:12 +0800 Subject: [PATCH] rollback trim --- .../spark/expression/OmniExpressionAdaptor.scala | 3 --- .../sql/execution/forsql/ColumnarFuncSuite.scala | 11 ----------- 2 files changed, 14 deletions(-) diff --git a/omnioperator/omniop-spark-extension/java/src/main/scala/com/huawei/boostkit/spark/expression/OmniExpressionAdaptor.scala b/omnioperator/omniop-spark-extension/java/src/main/scala/com/huawei/boostkit/spark/expression/OmniExpressionAdaptor.scala index e0a2359e0..ff34f63ad 100644 --- a/omnioperator/omniop-spark-extension/java/src/main/scala/com/huawei/boostkit/spark/expression/OmniExpressionAdaptor.scala +++ b/omnioperator/omniop-spark-extension/java/src/main/scala/com/huawei/boostkit/spark/expression/OmniExpressionAdaptor.scala @@ -530,9 +530,6 @@ object OmniExpressionAdaptor extends Logging { case regExpReplace: RegExpReplace => getRegExpReplaceStr(regExpReplace, exprsIndexMap) - case trim: StringTrim => - getTrimStr(trim, exprsIndexMap) - case floor: Floor => new JsonObject().put("exprType", "FUNCTION") .addOmniExpJsonType("returnType", floor.dataType) diff --git a/omnioperator/omniop-spark-extension/java/src/test/scala/org/apache/spark/sql/execution/forsql/ColumnarFuncSuite.scala b/omnioperator/omniop-spark-extension/java/src/test/scala/org/apache/spark/sql/execution/forsql/ColumnarFuncSuite.scala index ae401004e..99602b541 100644 --- a/omnioperator/omniop-spark-extension/java/src/test/scala/org/apache/spark/sql/execution/forsql/ColumnarFuncSuite.scala +++ b/omnioperator/omniop-spark-extension/java/src/test/scala/org/apache/spark/sql/execution/forsql/ColumnarFuncSuite.scala @@ -158,17 +158,6 @@ class ColumnarFuncSuite extends ColumnarSparkPlanTest { checkAnswer(res2, Seq(Row("你差世界"))) } - test("Test trim Function") { - spark.conf.set("spark.sql.optimizer.excludedRules", "org.apache.spark.sql.catalyst.optimizer.ConstantFolding") - val res1 = spark.sql("select trim(' hello ')") - assertOmniProjectHappened(res1) - checkAnswer(res1, Seq(Row("hello"))) - - val res2 = spark.sql("select trim(both '空' from '空稀少珍稀空')") - assertOmniProjectHappened(res2) - checkAnswer(res2, Seq(Row("稀少珍稀"))) - } - test("Test floor Function") { spark.conf.set("spark.sql.optimizer.excludedRules", "org.apache.spark.sql.catalyst.optimizer.ConstantFolding") val res1 = spark.sql("select floor(1.9)") -- Gitee