使用Sparksql計算數據庫表中某一列字段的中位數

該方法是基於Sparksql內置函數進行計算 我先上代碼: dataset和columnName最爲參數,columnName是字段名,dataset是什麼不說了,首先通過得到columnName字段在dataset中的下標位置,再通過withColumn在dataset表最後添加一列"tmpRowNumber",該列是通過row_number().over(Window.orderBy(colu
相關文章
相關標籤/搜索