从Scala中的StructType中提取行标记模式解析嵌套的XML

import org.apache.spark.sql.types.StructType
import org.apache.spark.sql.functions._
import org.apache.spark.sql.{SparkSession, DataFrame}

val spark = SparkSession.builder()
  .appName("XML Parsing")
  .master("local")
  .getOrCreate()

val xmlSchema = new StructType()
  .add("root", new StructType()
    .add("element1", StringType)
    .add("element2", IntegerType)
    .add("nested", new StructType()
      .add("nestedElement1", StringType)
      .add("nestedElement2", DoubleType)
    )
  )

val xmlData = spark.read
  .format("xml")
  .option("rowTag", "root")
  .schema(xmlSchema)
  .load("path/to/xml/file.xml")

val extractedData = xmlData.select(
  col("root.element1").alias("Element1"),
  col("root.element2").alias("Element2"),
  col("root.nested.nestedElement1").alias("NestedElement1"),
  col("root.nested.nestedElement2").alias("NestedElement2")
)