псевдоним для счета в Pyspark

Question

Я новичок в Pyspark. Я пытаюсь использовать псевдоним для функции подсчета. По какой-то причине, если я использую agg перед count, тогда alias работает, но если я не агрегирую, тогда alias дает мне ошибку.

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

не работает;

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

работает.

Я хотел понять проблему с 1-м запросом.

Answer 1

Вы можете попробовать это:

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

мы не можем напрямую подсчитывать псевдоним функции