scala - 找不到spark-sql中的聚合函数

Question

我是 Spark 新手，我正在尝试使用一些聚合功能，例如 sum 或 avg。我在 Spark-Shell 中的查询运行良好:

val somestats = pf.groupBy("name").agg(sum("days")).show()

当我尝试从 scala 项目运行它时，它不起作用，抛出错误消息

not found: value sum

我尝试添加

import sqlContext.implicits._
import org.apache.spark.SparkContext._

就在命令之前，但没有帮助。我的 Spark 版本是 1.4.1 我错过了什么吗？

Answer 1

您需要此导入:

import org.apache.spark.sql.functions._