1

我正在尝试使用 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)

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

4

0 回答 0