Как убрать символы новой строки в spark scala

Question

Приведенный ниже код работает нормально в python. У меня возникают трудности при написании эквивалентного кода в scala

map(lambda x:x[1].replace("\n","|"))

Что такое эквивалентный код в Scala?

Я попытался выполнить приведенную ниже команду в Scala и получая ошибку ниже.

scala> val read_rdd=sc.wholeTextFiles("/user/test/test1.txt").map(x => x[1].replace("\n","\u001F"))
<console>:1: error: identifier expected but integer literal found.

Answer 1

s c .wholeTextFiles () возвращает scala кортеж (String, String). Для доступа к членам используйте x._1 и x._2.

val read_rdd=sc.wholeTextFiles("e_edge.csv").map(x => x._2.replace("\n","\u001F"))