正在从 pyspark.sql.functions 导入 max/min/avg/col
Falling to import max/min/avg/col from pyspark.sql.functions
我正在使用 pycharm from pyspark.sql.functions import max, min, col
中的行。
但是,它无法识别这些函数,尽管它确实可以识别 log
- 来自 sql.functions
的函数。为什么 max
、min
和 col
没有被识别?
我的 pyspark 版本是 2.2,我的 python 版本是 3.6(通过 anaconda)。
它无法识别它们,因为 python 有它自己的 max, min
功能,或者您已经导入了具有这些功能的包,所以存在冲突。导入包时尝试使用 alias
:
import pyspark.sql.functions as psf
psf.max("my_col")
我正在使用 pycharm from pyspark.sql.functions import max, min, col
中的行。
但是,它无法识别这些函数,尽管它确实可以识别 log
- 来自 sql.functions
的函数。为什么 max
、min
和 col
没有被识别?
我的 pyspark 版本是 2.2,我的 python 版本是 3.6(通过 anaconda)。
它无法识别它们,因为 python 有它自己的 max, min
功能,或者您已经导入了具有这些功能的包,所以存在冲突。导入包时尝试使用 alias
:
import pyspark.sql.functions as psf
psf.max("my_col")