为了将整行作为附加参数传递给scala中的spark udf，我使用 struct("*") ，例如：
struct("*")
df.select(myUDF($"name",struct("*")))
如何在Pypark中执行相同的操作？
ykejflvf1#
其中一个方法是
df.select(myUDF(f.struct(*list(df.columns))))
1条答案
按热度按时间ykejflvf1#
其中一个方法是