Trying to use pivot function with pyspark for count aggregate

rbricks007 — Thu, 09 Nov 2023 20:46:48 GMT

I'm trying this code but getting the following error

testDF = (eventsDF .groupBy("user_id") .pivot("event_name") .count("event_name"))

TypeError: _api() takes 1 positional argument but 2 were given

Please guide how to fix the error

Re: Trying to use pivot function with pyspark for count aggregate

Krishnamatta — Fri, 10 Nov 2023 17:08:39 GMT

Try this

from pyspark.sql import functions as F testDF = (eventsDF .groupBy("user_id") .pivot("event_name") .agg(F.count("event_name")))