scala - Apache Spark ウィンドウ関数、サイズによるフィルター

Question

ウィンドウ関数を使用してウィンドウ内の平均を計算しようとしていますが、計算前に 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)

これを解決する方法はありますか？