如何将dict转换为spark map输出

from pyspark.sql import SparkSession

spark = SparkSession.builder \
    .appName("Dict to Spark Map") \
    .getOrCreate()

data = [
    {"name": "John", "age": 25, "city": "New York"},
    {"name": "Alice", "age": 30, "city": "San Francisco"},
    {"name": "Bob", "age": 35, "city": "Los Angeles"}
]

df = spark.createDataFrame(data)

from pyspark.sql.functions import col

df = df.select(col("name"), col("age"), col("city").alias("map_column"))

# 保存为Parquet文件
df.write.parquet("output.parquet")

# 执行SQL查询
df.createOrReplaceTempView("people")
result = spark.sql("SELECT name, age FROM people WHERE age > 30")
result.show()