count - Pyspark 中计数的别名

Question

我是 Pyspark 的新手。我正在尝试将别名用于计数功能。出于某种原因，如果我agg在前面使用countthenalias是有效的，但如果我没有聚合，那么这alias会给我错误。

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

不工作；

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

作品。

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

标签： countpysparkalias

Answer 1

你可以试试这个：

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

我们不能直接给计数函数起别名