Test Post
sfsfd import pyspark.sql.functions as F spark = ... # initialization df = spark.table("a").where(F.col("country") == "abc") df_unique = df.distinct() users_without_kids = df_unique.where(F.col("kid_count") == 0) obser = Observation() observed_df = users_without_kids.observe(observation, F.count(F.lit(1)).alias("row_count"))