Статус HTTP 500 - javax.servlet.ServletException: java.lang.UnsupportedClassVersionError [дубликат]

Здесь нет фильтра. И col("is_fav") == 1, и col("is_fav") == 0) являются просто булевыми выражениями, а count действительно не заботятся об их значении до тех пор, пока оно определено.

Существует множество способов решить эту проблему, например, используя simple sum:

from pyspark.sql.functions import sum, abs

gpd = df.groupBy("f")
gpd.agg(
    sum("is_fav").alias("fv"),
    (count("is_fav") - sum("is_fav")).alias("nfv")
)

или сделать игнорированные значения неопределенными (aka NULL ):

exprs = [
    count(when(col("is_fav") == x, True)).alias(c)
    for (x, c) in [(1, "fv"), (0, "nfv")]
]
gpd.agg(*exprs)