【问题标题】:How to replace empty string with \N in spark dataframe [duplicate]如何在火花数据框中用\ N替换空字符串[重复]
【发布时间】: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


    【解决方案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|
    +-----+-------+
    

    【讨论】:

      猜你喜欢
      • 2022-01-08
      • 1970-01-01
      • 2019-08-16
      • 1970-01-01
      • 1970-01-01
      • 2018-12-29
      • 1970-01-01
      • 2015-10-26
      • 1970-01-01
      相关资源
      最近更新 更多