scala - Apache Spark Window 函数，按大小过滤

Question

我正在尝试使用 Window 函数来计算窗口内的平均值，但在计算之前不包括 0。

val byClass = Window.partitionBy('class)    
val avgAge = avg('age).over(byClass)

我尝试像这样过滤大小，但没有运气。

val avgAge = avg('age).ge(lit(0)).over(byClusterHash)

最后，

val results = reports.select('*, avgAge as 'avg).show(2000)

知道如何解决这个问题吗？