我正在尝试创建一个简单的、可重用的函数来聚合不同级别和组上的值。输入应为: 现有数据帧 group by的变量(单列或列表) 要聚合的变量(同上) 要应用的函数(可以是一个特定的函数,也可以是它们的列表)。我保持简单的求和,平均,最小,最大值,等等。当我有一个单独的函数或一个列表时,我让它可以工作,但是当涉及到聚合变量时,我被困在将它们的列表引入到函数中 def aggregate(dataframe,grouping,aggregation,functionsdf = data
我正在尝试教自己Scala,并使用IntelliJ的想法作为我的IDE。我已经启动IntelliJ的shell,运行console,然后输入以下内容:import org.apache.spark.sqlmember of val dataFrames = Seq(df.featuresGroup1(<em