小编Yor*_*ghe的帖子

我正在尝试解决以下错误（我正在使用Databricks平台和Spark 2.0）

tweets_cleaned.createOrReplaceTempView("tweets_cleanedSQL")
def Occ(keyword):
  occurences = spark.sql("SELECT * \
                                FROM tweets_cleanedSQL \
                                WHERE LOWER(text) LIKE '%" + keyword + "%' \
                            ")
  return occurences.count()


occurences_udf = udf(Occ)

如果运行此代码，则会收到以下错误：

py4j.Py4JException：方法getnewargs（[]）不存在==>仅在尝试定义udf时发生错误。