Skip to content

Commit c9dbfcc

Browse files
viiryarxin
authored andcommitted
[SPARK-11743][SQL] Move the test for arrayOfUDT
A following pr for #9712. Move the test for arrayOfUDT. Author: Liang-Chi Hsieh <viirya@gmail.com> Closes #10538 from viirya/move-udt-test.
1 parent 5adec63 commit c9dbfcc

File tree

1 file changed

+2
-13
lines changed

1 file changed

+2
-13
lines changed

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/encoders/RowEncoderSuite.scala

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,8 @@ class RowEncoderSuite extends SparkFunSuite {
108108
.add("arrayOfArrayOfString", ArrayType(arrayOfString))
109109
.add("arrayOfArrayOfInt", ArrayType(ArrayType(IntegerType)))
110110
.add("arrayOfMap", ArrayType(mapOfString))
111-
.add("arrayOfStruct", ArrayType(structOfString)))
111+
.add("arrayOfStruct", ArrayType(structOfString))
112+
.add("arrayOfUDT", arrayOfUDT))
112113

113114
encodeDecodeTest(
114115
new StructType()
@@ -130,18 +131,6 @@ class RowEncoderSuite extends SparkFunSuite {
130131
new StructType().add("array", arrayOfString).add("map", mapOfString))
131132
.add("structOfUDT", structOfUDT))
132133

133-
test(s"encode/decode: arrayOfUDT") {
134-
val schema = new StructType()
135-
.add("arrayOfUDT", arrayOfUDT)
136-
137-
val encoder = RowEncoder(schema)
138-
139-
val input: Row = Row(Seq(new ExamplePoint(0.1, 0.2), new ExamplePoint(0.3, 0.4)))
140-
val row = encoder.toRow(input)
141-
val convertedBack = encoder.fromRow(row)
142-
assert(input.getSeq[ExamplePoint](0) == convertedBack.getSeq[ExamplePoint](0))
143-
}
144-
145134
test(s"encode/decode: Product") {
146135
val schema = new StructType()
147136
.add("structAsProduct",

0 commit comments

Comments
 (0)