Estoy usando scala, spark, IntelliJ y maven.

He usado el siguiente código:

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")

y

val score= list.withColumn("scr", lit(0))

Pero cuando intenta construir usando Maven, obteniendo los siguientes errores:

error: no encontrado: valor cuando

y

error: no encontrado: valor encendido

por$ y=== He usadoimport sqlContext.implicits.StringToColumn y está funcionando bien No se produjo ningún error en el momento de la construcción de Maven. Pero paralit(0) ywhen lo que necesito importar o hay alguna otra forma de resolver el problema.