Estou usando scala, spark, IntelliJ e maven.

Eu usei o código abaixo:

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

e

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

Mas quando você tenta construir usando o maven, fica abaixo dos erros -

erro: não encontrado: valor quando

e

erro: não encontrado: valor aceso

Para$ e=== Eu tenho usadoimport sqlContext.implicits.StringToColumn e está funcionando bem. Nenhum erro ocorreu no momento da construção do maven.lit(0) ewhen o que eu preciso importar ou existe outra maneira de resolver o problema.