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
相关文章
相关标签/搜索