11-09-2023 12:46 PM
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
11-21-2023 01:12 AM - edited 11-23-2023 01:37 AM
Hi @rbricks007 ,The error you’re encountering in your PySpark code is related to the usage of the pivot function.
View solution in original post
11-10-2023 09:08 AM
Try this
from pyspark.sql import functions as F testDF = (eventsDF .groupBy("user_id") .pivot("event_name") .agg(F.count("event_name")))
never-displayed
Join our fast-growing data practitioner and expert community of 80K+ members, ready to discover, help and collaborate together while making meaningful connections.
Click here to register and join today!
Engage in exciting technical discussions, join a group with your peers and meet our Featured Members.