This is an automated email from the ASF dual-hosted git repository. jackylk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/carbondata.git
The following commit(s) were added to refs/heads/master by this push: new f6c7564 Revert "[HOTFIX] Fix UDF, Hex SQL Functions test case for binary" f6c7564 is described below commit f6c7564a539997e92215c30c7eb1b4ee859ff981 Author: Jacky Li <jacky.li...@qq.com> AuthorDate: Wed Dec 25 19:27:23 2019 +0800 Revert "[HOTFIX] Fix UDF, Hex SQL Functions test case for binary" This reverts commit 3e0a80bee0c9d347eeb70b8d639a1b7f6d06b143. --- .../datasource/SparkCarbonDataSourceBinaryTest.scala | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/integration/spark-datasource/src/test/scala/org/apache/spark/sql/carbondata/datasource/SparkCarbonDataSourceBinaryTest.scala b/integration/spark-datasource/src/test/scala/org/apache/spark/sql/carbondata/datasource/SparkCarbonDataSourceBinaryTest.scala index 894d5b6..9a3a9f0 100644 --- a/integration/spark-datasource/src/test/scala/org/apache/spark/sql/carbondata/datasource/SparkCarbonDataSourceBinaryTest.scala +++ b/integration/spark-datasource/src/test/scala/org/apache/spark/sql/carbondata/datasource/SparkCarbonDataSourceBinaryTest.scala @@ -469,17 +469,11 @@ class SparkCarbonDataSourceBinaryTest extends FunSuite with BeforeAndAfterAll { """.stripMargin) sql("insert into carbon_table select * from hivetable") - def getHexString(str: String) = { - str.toList.map(_.toInt.toHexString).mkString - } - sqlContext.udf.register("decodeHex", (str: String) => - Hex.decodeHex(getHexString(str).toCharArray)) - sqlContext.udf.register("encodeHex", (str: String) => - org.apache.spark.sql.catalyst.expressions.Hex.unhex(getHexString(str).getBytes)) + sqlContext.udf.register("decodeHex", (str: String) => Hex.decodeHex(str.toCharArray)) sqlContext.udf.register("decodeBase64", (str: String) => Base64.decodeBase64(str.getBytes())) val udfHexResult = sql("SELECT decodeHex(image) FROM carbon_table") - val unhexResult = sql("SELECT encodeHex(image) FROM carbon_table") + val unhexResult = sql("SELECT unhex(image) FROM carbon_table") checkAnswer(udfHexResult, unhexResult) val udfBase64Result = sql("SELECT decodeBase64(image) FROM carbon_table")