将包含字典列表的dataframe转换为pyspark中的几行

from pyspark.sql import SparkSession
from pyspark.sql.types import StructType, StructField, StringType

spark = SparkSession.builder.appName("DataFrame to Rows").getOrCreate()

data = [
    {"name": "John", "age": 25},
    {"name": "Alice", "age": 30},
    {"name": "Bob", "age": 35}
]
df = spark.createDataFrame(data)

schema = StructType([
    StructField("name", StringType(), True),
    StructField("age", StringType(), True)
])

rows_rdd = df.rdd.map(lambda row: row.asDict())
rows = rows_rdd.map(lambda row: Row(**row))

new_df = spark.createDataFrame(rows, schema)