如何使用avg替换空值来过滤Dataframe中的数据运行此代码片段时：
df.select(colname).agg(avg(colname))
我收到这个例外：
name error: avg not defined
我还能用什么命令？
qnyhuwrf1#
这样的解决方案会更干净：
import pyspark.sql.functions as F df.select(colname).agg(F.avg(colname))
rdrgkggo2#
知道了。。有用处。。
from pyspark.sql.functions import * from pyspark.sql.types import *
2条答案
按热度按时间qnyhuwrf1#
这样的解决方案会更干净：
rdrgkggo2#
知道了。。
有用处。。