我有一个Spark SQL DataFrame:
user1 item1 rating1
user1 item2 rating2
user1 item3 rating3
user2 item1 rating4
...
如何按用户分组,然后TopN使用Scala从每个组返回项目？
使用Python的相似代码:
df.groupby("user").apply(the_func_get_TopN)