Spark:如何定义嵌套模式？

import org.apache.spark.sql.types._

// 定义嵌套模式的结构体类型
val addressType = StructType(Seq(
  StructField("street", StringType, nullable = false),
  StructField("city", StringType, nullable = false),
  StructField("zip", StringType, nullable = false)
))

// 定义包含嵌套模式的结构体类型
val personType = StructType(Seq(
  StructField("name", StringType, nullable = false),
  StructField("age", IntegerType, nullable = false),
  StructField("address", addressType, nullable = false)
))

// 创建一个DataFrame，使用定义好的嵌套模式
val data = Seq(
  Row("John Doe", 30, Row("123 Main St", "San Francisco", "94101")),
  Row("Jane Smith", 25, Row("456 Elm St", "New York", "10001"))
)

val spark = SparkSession.builder().appName("NestedSchemaExample").getOrCreate()
val df = spark.createDataFrame(spark.sparkContext.parallelize(data), personType)

df.show()