Revert "[HOTFIX] Fix UDF, Hex SQL Functions test case for binary"
This reverts commit 3e0a80bee0c9d347eeb70b8d639a1b7f6d06b143.
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 @@
""".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")
