Hinzufügen von zwei Spalten aus einem Datenrahmen in Scala

Question

Ich habe zwei Spalten Alter und Gehalt in DF gespeichert. Ich möchte nur einen Scala-Code schreiben, um diese Werte spaltenweise hinzuzufügen. Ich versuchte

val age_1 = df.select("age") 
val salary_1=df.select("salary") 
val add = age_1+salary_1 

gibt mir Fehler. bitte helfen

Answer 1

Im folgenden spark ist eine Instanz SparkSession, so dass der Import hat nach die Instanziierung spark zu kommen.

-Notation $ kann hier verwendet werden, durch Funken implicits mit

import spark.implicits._ 

dann $ -Notation

val add = df.select($"age" + $"salary") 

final scala Code verwenden, importieren:

import spark.implicits._ 
val add = df.select($"age" + $"salary") 

Apache doc