在 PySpark 的同一行上用值透视聚合填充列

Question

我需要用答案填充列的数据透视聚合。

下面是例子，谢谢！

Input

id	question	answer
1	quest_1	Good
1	quest_2	Bad
2	quest_1	Bad
2	quest_2	Good
2	quest_3	Quite Good

Output

id	quest_1	quest_2	quest_3
1	Good	Bad	NULL
2	Bad	Good	Quite Good

---

Answer 1

做一个支点

 df.groupby('id').pivot('question').agg(first('answer')).show()