我尝试在 Dataframe 上运行聚合。然后我想计算每一列上的不同值。我生成了一个聚合字典，如下所示：

from pyspark.sql.functions import countDistinct

expr = {x: "countDistinct" for x in df.columns if x is not 'id'}
df.groupBy("id").agg(expr).show()

我收到错误：
分析异常：未定义的函数：“countdistinct”。此函数既不是注册的临时函数，也不是在数据库“default”中注册的永久函数。
如果我直接使用'countDistinct'，它就可以工作：

df.groupBy("id").agg(countDistinct('hours'))

输出[1]： Dataframe [id：int，计数（小时）：二进制数]
这不起作用：

df.groupBy("id").agg({'hours':'countDistinct'}).show()

分析异常：未定义的函数：“countdistinct”。此函数既不是注册的临时函数，也不是在数据库“default”中注册的永久函数。
有什么想法可以解决这个问题吗？