[carbondata] branch master updated: Revert "[HOTFIX] Fix UDF, Hex SQL Functions test case for binary"

[jackylk]

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")