Github user arunmahadevan commented on a diff in the pull request:
https://github.com/apache/spark/pull/22251#discussion_r213407599
--- Diff:
external/avro/src/test/scala/org/apache/spark/sql/avro/AvroSuite.scala ---
@@ -1099,6 +1098,27 @@ class AvroSuite extends QueryTest with
SharedSQLContext with SQLTestUtils {
}
}
+ test("check namespace - toAvroType") {
+ val sparkSchema = StructType(Seq(
+ StructField("name", StringType, nullable = false),
+ StructField("address", StructType(Seq(
+ StructField("city", StringType, nullable = false),
+ StructField("state", StringType, nullable = false))),
+ nullable = false)))
+ val employeeType = SchemaConverters.toAvroType(sparkSchema,
+ recordName = "employee",
+ nameSpace = "foo.bar")
--- End diff --
Added a test case for toAvroType with empty namespace
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
