您链接的问题是使用Scala
object。Scala
object是单例,您可以
apply直接使用method。
在这里,您使用一个无效函数返回一个
UserDefinedFunctionco类的对象,您必须首先调用该函数:
_f = sc._jvm.com.test.ScalaPySparkUDFs.testUDFFunction1() # Note () at the endColumn(_f.apply(_to_seq(sc, [col], _to_java_column)))

您链接的问题是使用Scala
object。Scala
object是单例,您可以
apply直接使用method。
在这里,您使用一个无效函数返回一个
UserDefinedFunctionco类的对象,您必须首先调用该函数:
_f = sc._jvm.com.test.ScalaPySparkUDFs.testUDFFunction1() # Note () at the endColumn(_f.apply(_to_seq(sc, [col], _to_java_column)))