Spark：列の名前を変更して行の値を更新する

sparkデータフレームを使用して列の名前を変更し、条件を追加します。Spark：列の名前を変更して行の値を更新する

例：「ソースコード」に名前を変更する列「コード」があり、条件を追加したいとします。列の値が「A」に等しいときは「Agent」に名前を変更し、値が「O」の場合は「Other」に名前を変更する必要があります。

2017-01-04 SFatima

列名の変更？ – Natalia

@Natalia Spark Scalaを使用しています。 – SFatima

この会話をチェック[http://stackoverflow.com/questions/35592917/renaming-column-names-of-a-data-frame-in-spark-scala](http://stackoverflow.com/questions/35592917/）スパン・スケーラ・データ・フレーム・イン・スパーク・スカラ） –

df.withColumnRenamed("oldName", "newName")

更新値を使用している言語

val newColumnValue = df("c")... //some calculation 
df.withColumn("updatedValue", newColumn)

出典

2017-01-04 22:04:50 Natalia

Spark：列の名前を変更して行の値を更新する

答えて

関連する問題