filter count(1) over partition() pyspark code example Example: filter in pyspark df.filter(df.state == "OH")