從pyspark.sql.functions輸入max/min/avg/col

Question

我在pycharm from pyspark.sql.functions import max, min, col中使用該行。

但是，它不能識別這些功能，即使它識別出log - 來自sql.functions的功能。爲什麼max,min和col得到認可？

我的pyspark版本是2.2，我的python版本是3.6（通過anaconda）。

Answer 1

它不識別它們，因爲python有它自己的max, min函數，或者你已經用這些函數導入了一個包，所以有衝突。導入包裝時，請嘗試使用alias：

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