从pyspark.sql.function中导入max。

Question

试图用3.0.0版本得到以下 "from pyspark.sql.function import col,max"，但没有成功。在新版本中是否有改变？

Answer 1

我想建议你不要直接导入，因为它会覆盖同名的python内置函数，如max，sum等。

所以，你应该像这样导入--把pyspark.sql.function导入为F。

现在你可以像使用F.max()那样使用它了。