Scala代码返回avg和abs函数错误

Question

在Scala中运行代码时，函数abs和avg出现以下错误。

command-3092209798892765:2: error: not found: value abs
.filter(abs(t2("engine_size") - t1("engine_size")) <= BigDecimal("0.1"))
^
command-3092209798892765:4: error: not found: value avg
.agg(avg("sale_price").as("average_price")).collect()
^

Scala代码是

t1.join(t2, Seq("make", "model"))
.filter(abs(t2("engine_size") - t1("engine_size")) <= BigDecimal("0.1"))
.groupBy("registration")
.agg(avg("sale_price").as("average_price")).collect()

如果我需要导入函数，你能告诉我吗？或者如何修复错误

Answer 1

使用import org.apache.spark.sql.functions._来使用这些函数。