用总行和列计数PySpark数据帧中的空值

from pyspark.sql.functions import col, sum

# 假设数据帧名为df
null_counts = df.agg(*[sum(col(c).isNull().cast("int")).alias(c) for c in df.columns])

# 打印每列中的空值数量
null_counts.show()

from pyspark.sql.functions import col

# 假设数据帧名为df
null_counts = df.withColumn("null_count", sum(col(c).isNull().cast("int") for c in df.columns))

# 打印每行中的空值数量
null_counts.show()