префикс нескольких имен столбцов в искре

Question

Я написал следующий код scala:

 val someDF = Seq(
 |   (8, "bat"),
 |   (64, "mouse"),
 |   (-27, "horse")
 | ).toDF("number", "word")

Моя цель - изменить имена столбцов на "pap_number" и "pap_word"

Я написал это:

val list = someDF.columns

, а затем

val result = list.foldLeft(df){(acc, names ) =>
 |   acc.withColumnRenamed(names, "pap_".concat(names)
 | }

Но это не сработает.

Answer 1

Вы пропустили одну скобку и указали неверный df.

scala> someDF.columns.foldLeft(someDF){ (acc, names) =>
 | acc.withColumnRenamed(names, "pap_".concat(names))
 | }
res2: org.apache.spark.sql.DataFrame = [pap_number: int, pap_word: string]