如何将Pyspark dataframe转换为Python字典

from pyspark.sql import SparkSession

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

# 从文件加载DataFrame
df = spark.read.csv("path/to/file.csv", header=True, inferSchema=True)

# 从列表创建DataFrame
data = [("Alice", 25), ("Bob", 30), ("Charlie", 35)]
df = spark.createDataFrame(data, ["Name", "Age"])

rows = df.collect()

dictionary = {row["col1"]: row["col2"] for row in rows}

from pyspark.sql import SparkSession

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

# 加载或创建DataFrame
df = spark.read.csv("path/to/file.csv", header=True, inferSchema=True)

# 将DataFrame转换为Python列表
rows = df.collect()

# 将Python列表转换为字典
dictionary = {row["col1"]: row["col2"] for row in rows}

print(dictionary)