aboutsummaryrefslogtreecommitdiff
path: root/sql/core/src/test/scala/org/apache/spark/sql/StringFunctionsSuite.scala
diff options
context:
space:
mode:
Diffstat (limited to 'sql/core/src/test/scala/org/apache/spark/sql/StringFunctionsSuite.scala')
-rw-r--r--sql/core/src/test/scala/org/apache/spark/sql/StringFunctionsSuite.scala10
1 files changed, 10 insertions, 0 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/StringFunctionsSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/StringFunctionsSuite.scala
index 628da95298..f40233db0a 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/StringFunctionsSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/StringFunctionsSuite.scala
@@ -103,6 +103,16 @@ class StringFunctionsSuite extends QueryTest {
Row("AQIDBA==", bytes))
}
+ test("string / binary substring function") {
+ // scalastyle:off
+ // non ascii characters are not allowed in the code, so we disable the scalastyle here.
+ val df = Seq(("1世3", Array[Byte](1, 2, 3, 4))).toDF("a", "b")
+ checkAnswer(df.select(substring($"a", 1, 2)), Row("1世"))
+ checkAnswer(df.select(substring($"b", 2, 2)), Row(Array[Byte](2,3)))
+ checkAnswer(df.selectExpr("substring(a, 1, 2)"), Row("1世"))
+ // scalastyle:on
+ }
+
test("string encode/decode function") {
val bytes = Array[Byte](-27, -92, -89, -27, -115, -125, -28, -72, -106, -25, -107, -116)
// scalastyle:off