我无法在数据帧上运行计数或显示,并且出现 nullpointerException 错误。这里可能有什么问题。以下是分配给 df 的数据。请帮助
Item_table = spark.sql("""select ts as tr_ts,from_location, to_location,
来自 ext_table 的项目
其中项目在(从 ds_df b 中选择项目
其中 a.to_location==b.to_location) 和
到_日期(tr_ts)
>=(从 min_dt_df 中选择 Min_date)和
截止日期(tr_ts)<= to_date('{}') """.
格式(run_date)).dropDuplicates()