Pyspark 中计数的别名

Question

我是 Pyspark 的新手。我正在尝试使用计数函数的别名。出于某种原因，如果我agg在前面使用countthenalias就可以工作，但如果我没有聚合，那么就会alias给我错误。

.(count("firstName").alias("cnt"))

不起作用；

.agg(count("firstName").alias("cnt"))

作品。

我想了解第一个查询的问题。

Answer 1

你可以试试这个：

.count().withColumnRenamed("count","cnt")

我们不能直接为 count 函数添加别名