scala - Apache Spark Dataframe Groupby agg() 用于多列

Question

我有一个 DataFrame有 3 列，即 Id, First Name, Last Name
我要申请 GroupBy基于Id并想收藏First Name, Last Name列作为列表。

示例:-我有一个这样的 DF

+---+-------+--------+
|id |fName  |lName   |
+---+-------+--------+
|1  |Akash  |Sethi   |
|2  |Kunal  |Kapoor  |
|3  |Rishabh|Verma   |
|2  |Sonu   |Mehrotra|
+---+-------+--------+

我想要这样的输出

+---+-------+--------+--------------------+
|id |fname           |lName               |
+---+-------+--------+--------------------+
|1  |[Akash]         |[Sethi]             |
|2  |[Kunal, Sonu]   |[Kapoor, Mehrotra]  |
|3  |[Rishabh]       |[Verma]             |
+---+-------+--------+--------------------+

提前致谢

Answer 1

您可以像这样聚合多个列:

df.groupBy("id").agg(collect_list("fName"), collect_list("lName"))

它会给你预期的结果。