Я получил вышеупомянутую ошибку при запуске кадра данных в блоках данных с использованием Pyspark. Я не знаю, как решить это и где я ошибся. Код выглядит следующим образом:
df_inner_select = df_promodata_daypart.select(df_promodata_daypart.sub_master_id,df_promodata_daypart.sub_campaign_id,df_promodata_daypart.resolved_network,df_promodata_daypart.hh_id,df_promodata_daypart.type,df_df_promodata_daypart.localpromoadviewstarttime_min).alias("viewerbytype").groupby(df_promodata_daypart.sub_master_id,df_promodata_daypart.sub_campaign_id,df_promodata_daypart.resolved_network,df_promodata_daypart.hh_id,df_promodata_daypart.localpromoadviewstarttime_min).agg(F.sum(F.when(df_promodata_daypart.type=="NonTargeted",1).otherwise(0).alias("NonTargeted_count")),F.sum(F.when(df_promodata_daypart.type=="Targeted").alias("Targeted_count")))
, а также здесь мне нужно получить количество столбцов типа, как указано в кадре данных. Может ли кто-нибудь помочь мне решить эту проблему с максимально быстрым ответом?
Заранее большое спасибо.