3

年齢と給与の 2 つの列が DF に格納されています。これらの値を列ごとに追加するためのスカラ コードを書きたいだけです。私は試した

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

エラーが発生します。助けてください

4

1 に答える 1

11

以下sparkは のインスタンスでSparkSessionあるため、インポートはのインスタンス化の後にspark行う必要があります。

ここで$ 表記を使用するには、spark の暗黙的なものを次のようにインポートします。

import spark.implicits._ 

次に、$ 表記を使用します

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

最終的なスカラ コード:

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

アパッチドキュメント

于 2016-10-14T11:00:41.550 に答える