scala - 尝试使用 Spark 聚合函数时无法解析符号

Question

我想尝试类似的东西

但是，我收到了来自想法的警告，例如

我应该怎么办？

标签： scalaapache-sparkintellij-ideaapache-spark-sql

Answer 1

您的导入声明应该是import org.apache.spark.sql.functions._

._通配符导入在哪里。org.apache.spark.sql.functionsobject 定义了要使用的内置标准函数。

然后你可以使用这样的函数：

df.groupBy(df("pt")).agg(max("id"), mean("encodedType")).show

您可以在此链接中查看示例