isnotnull.py

from pyspark.sql.functions import *

# Example 1
fact_df = fact_df.filter(col('colname').isNotNull()).alias('fact_df')

# Example 2
fact_df = fact_df.filter(col('colname').isNull()).alias('fact_df')

# Example 3
fact_df = fact_df.withColumn('colname', when(col('colname').isNotNull(), col('colname2')).otherwise(col('colname3'))).alias('fact_df')

# Example 4
fact_df = fact_df.withColumn('colname', when(col('colname').isNull(), col('colname2')).otherwise(col('colname3'))).alias('fact_df')