sparkdataframe 对多列进行先filter后求均值

本文主要是介绍sparkdataframe 对多列进行先filter后求均值，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

import org.apache.spark.sql.{Column, DataFrame, Dataset, Row, SparkSession}
spark dataframe 对多列进行先filter后求均值
meanDf = df.select(df.columns.map(k=>mean(when(col(k)>0, col(k))).alias(k+“mean”)): _*)

spark dataFrame 多列drop
judgeCols：Array[String]
var df = frame.drop(judgeCols:_*)

这篇关于sparkdataframe 对多列进行先filter后求均值的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---