scala - 如何在spark数据框中用\N替换空字符串

Question

这个问题已经有答案了:

How to replace empty values in a column of DataFrame? (3 个回答)

Replace null values in Spark DataFrame (3 个回答)

Replace Empty values with nulls in Spark Dataframe (1 个回答)

已关闭 5 年前。

如何用 \N 替换空字符串在 Spark dataframe .

我尝试了以下一个:

Df.na.replace(Seq("column1"),Map("" -> null)).na.fill("\N", Seq("column1"))

它向我抛出一个错误。

Answer 1

你必须像下面这样做

//Input df

+-----+-------+
| name|address|
+-----+-------+
|Manoj|Chennai|
|     |  Delhi|
|Alice|       |
+-----+-------+

//Replacement logic

df.na.replace(Seq("name","address"),Map(""->"\\n")).show

//Output df
+-----+-------+
| name|address|
+-----+-------+
|Manoj|Chennai|
|   \n|  Delhi|
|Alice|     \n|
+-----+-------+