在不使用pandas的情况下将数据帧转换为pyspark中的字典

from pyspark.sql import SparkSession
from pyspark.sql.functions import collect_list

spark = SparkSession.builder.getOrCreate()

df = spark.read.format("csv").option("header", "true").load("data.csv")

result = df.groupBy().agg(collect_list(df.columns[0]).alias("keys"), collect_list(df.columns[1]).alias("values")).collect()[0].asDict()

print(result)