【发布时间】:2020-09-24 00:54:56
【问题描述】:
我的数据文件中有一些带有“”(双引号)的记录。我需要使用 regexp_replace 函数将这些引号替换为 scala 中的空格。
示例:regexp_replace(column_name, '\"' ," ") 但是当我尝试这样做时,我收到了一些错误“未关闭”字符串文字。
【问题讨论】:
-
regexp_replace(column_name, '\"', " ")
-
你也可以使用
translate函数 -
@AlexOtt 感谢您的回复。 Translate 和 regexp_replace 函数返回单位类型,但我想在 scala 中返回字符串类型。
-
他们返回
Column类型——这就是它在 Spark SQL 中的工作方式。如果你只需要替换String中的所有内容,那么你需要使用.replaceAll -
@AlexOtt 但我需要使用 regexp_replace 将双引号(\")替换为空格(“”)。
标签: scala apache-spark