Spark裏面Agg自定義聚合函數 --中位數(Median)

Spark自己的實現中位數不能用於groupBy的agg函數,下面代碼實如今agg中調用sql 原生Spark計算中位數express df2.stat.approxQuantile("value", Array(0.5), 0) 1.定義方法 import org.apache.spark.sql.functions._ import org.apache.spark.sql.Column im
相關文章
相關標籤/搜索