我正在使用scala,spark,IntelliJ和maven。错误:未找到:值点亮/当 - 火花scala
我用下面的代码:
val joinCondition = when($"exp.fnal_expr_dt" >= $"exp.nonfnal_expr_dt",
$"exp.manr_cd"===$"score.MANR_CD")
val score = exprDF.as("exp").join(scoreDF.as("score"),joinCondition,"inner")
和
val score= list.withColumn("scr", lit(0))
但是,当试图建立使用maven,得到下面的错误 -
error: not found: value when
和
error: not found: value lit
对于$
和===
我已经使用import sqlContext.implicits.StringToColumn
它工作正常。 Maven构建时没有发生错误,但是对于lit(0)
和when
我需要导入或者有任何其他方式来解决问题。
您需要导入'org.apache.spark.sql.functions' – cheseaux
我已经回答了您的部分问题。什么是列表的类型?它是一个DataFrame? – eliasah
@eliasah:两者都是Dataframe – Avijit