正在从 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 的函数。为什么 maxmincol 没有被识别?

我的 pyspark 版本是 2.2,我的 python 版本是 3.6(通过 anaconda)。

它无法识别它们,因为 python 有它自己的 max, min 功能,或者您已经导入了具有这些功能的包,所以存在冲突。导入包时尝试使用 alias

import pyspark.sql.functions as psf
psf.max("my_col")