Присвоение функции Spark SQL переменной

Question

Я хочу назначить искровую функцию SQL переменной. Например:

    val func = org.apache.spark.sql.functions.max(_)

Теперь это способ выполнения частичных функций. Но когда я делаю это, я получаю эту ошибку:

  Cannot resolve overloaded method max

Поиск в Интернете, не удалось найти решение. У кого-нибудь есть идея?

Answer 1

Примечание max - перегруженная функция:

Так что либо:

import org.apache.spark.sql.Column

scala> val func: Column => Column = org.apache.spark.sql.functions.max
func: org.apache.spark.sql.Column => org.apache.spark.sql.Column = <function1>

или

scala> val func: String => Column = org.apache.spark.sql.functions.max
func: String => org.apache.spark.sql.Column = <function1>

Из интереса, почему ты хочешь это сделать?