Ich benutze Scala, Spark, IntelliJ und Maven.

Ich habe folgenden Code verwendet:

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

un

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

Aber wenn du versuchst, mit maven zu bauen, bekommst du weniger Fehler -

Fehler: nicht gefunden: Wert, wenn

un

Fehler: nicht gefunden: Wert leuchtet

Zum$ und=== Ich habe benutztimport sqlContext.implicits.StringToColumn und es funktioniert gut. Zum Zeitpunkt der Erstellung des maven ist kein Fehler aufgetreten. Aber fürlit(0) undwhen was muss ich importieren oder gibt es eine andere Möglichkeit, das Problem zu beheben.