How to get names of columns with missing values in PySpark
When we do data validation in PySpark, it is common to need all columns’ column names with null values. In this article, I show how to get those names for every row in the DataFrame.
First, I assume that we have a DataFrame df
and an array all_columns
, which contains the names of the columns we want to validate.
We have to create a column containing an array of strings that denote the column names with null values. Therefore, we have to use the when
function to check whether the value is null and pass the column names as the literal value. We use the *
to unpack the array produced by for comprehension into a Spark array:
1
2
3
missing_column_names = array(*[
when(col(c).isNull(),lit(c)) for c in all_column
])
After that, we assign the values to a new column in the DataFrame:
1
df = df.withColumn("missing_columns", missing_column_names)
You may also like
- How to speed up a PySpark job
- How to combine two DataFrames with no common columns in Apache Spark
- How to run PySpark code using the Airflow SSHOperator
- What is the difference between a transformation and an action in Apache Spark?
- How to derive multiple columns from a single column in a PySpark DataFrame
Remember to share on social media! If you like this text, please share it on Facebook/Twitter/LinkedIn/Reddit or other social media.
If you want to contact me, send me a message on LinkedIn or Twitter.
Would you like to have a call and talk? Please schedule a meeting using this link.