【发布时间】:2018-07-19 16:37:17
【问题描述】:
如何在 spark dataframe 中用 \N 替换空字符串。
我尝试了以下一个:
Df.na.replace(Seq("column1"),Map("" -> null)).na.fill("\N", Seq("column1"))
它给我一个错误。
【问题讨论】:
标签: scala apache-spark apache-spark-sql
如何在 spark dataframe 中用 \N 替换空字符串。
我尝试了以下一个:
Df.na.replace(Seq("column1"),Map("" -> null)).na.fill("\N", Seq("column1"))
它给我一个错误。
【问题讨论】:
标签: scala apache-spark apache-spark-sql
你必须像下面那样做
//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|
+-----+-------+
【讨论】: