小编Kyu*_*nam的帖子

在expr()中使用lit()

该行:

df.withColumn("test", expr("concat(lon, lat)")) 
Run Code Online (Sandbox Code Playgroud)

可以正常工作,但是

df.withColumn("test", expr("concat(lon, lit(','), lat)"))
Run Code Online (Sandbox Code Playgroud)

产生以下异常:

org.apache.spark.sql.AnalysisException:未定义的函数:'lit'。该功能既不是注册的临时功能,也不是在数据库“默认”中注册的永久功能。org.apache.spark.sql.catalyst.analysis.Analyzer $ LookupFunctions $$ anonfun $ apply $ 15 $ anonfun $ applyOrElse $ 49.apply(Analyzer.scala:1198)的第1行pos 12

为什么?解决方法是什么?

scala apache-spark apache-spark-sql databricks

6
推荐指数
1
解决办法
3531
查看次数