2016-10-14 7 views
3

DFに2つの列の年齢と給与が格納されています。私は、これらの値を列方向に追加するためのスカラコードを作成したいだけです。試しましたスカラーのデータフレームから2つの列を追加する

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

私にはエラーが発生します。 SparkSessionのインスタンスであるため、インポートがsparkのインスタンス化した後を来るように持って、次のspark

答えて

5

を助けてください。

$ -notationは、その後使用

import spark.implicits._ 

でスパーク暗黙をインポートして、ここで使用することができます$ -notation

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

最終Scalaのコード:

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

Apache doc

関連する問題