Передайте всю строку как дополнительный аргумент в UDF в PySpark - PullRequest
1 голос
/ 18 июня 2020

Чтобы передать всю строку в качестве дополнительного аргумента Spark UDF в Scala, я использую struct("*"), например:

df.select(myUDF($"name",struct("*")))

Как сделать то же самое в PySpark?

1 Ответ

1 голос
/ 18 июня 2020

Один из способов сделать это:

df.select(myUDF(f.struct(*list(df.columns))))
...