如何用 \N
替换空字符串在 Spark dataframe
.
我尝试了以下一个:
Df.na.replace(Seq("column1"),Map("" -> null)).na.fill("\N", Seq("column1"))
它向我抛出一个错误。
最佳答案
你必须像下面这样做
//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|
+-----+-------+
关于scala - 如何在spark数据框中用\N替换空字符串,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51427874/