我在 Pyspark 中有以下数据框
+----+-------+-----+
|name|subject|score|
+----+-------+-----+
| Tom| math| 90|
| Tom|physics| 70|
| Amy| math| 95|
+----+-------+-----+
我使用collect_list并struct从pyspark.sql.functions
df.groupBy('name').agg(collect_list(struct('subject', 'score')).alias('score_list'))
获取以下数据框
+----+--------------------+
|name| score_list|
+----+--------------------+
| Tom|[[math, 90], [phy...|
| Amy| [[math, 95]]|
+----+--------------------+
我的问题是如何将最后一列score_list转换为字符串并将其转储到 csv 文件中，如下所示
Tom (math, 90) | (physics, 70)
Amy (math, 95)
感谢任何帮助，谢谢。
更新：这是一个类似的问题，但并不完全相同，因为它直接从string另一个string. 就我而言，我想首先转移string到collect_list<struct>并最终将其字符串化collect_list<struct>。