代码之家 › 专栏 › 技术社区 › Surender Raja

如何替换所有以字符串开头的特殊字符

apache-spark-sql

-1

Surender Raja · 技术社区 · 5 年前

输入:

+---------+
|full_name|
+---------+
|    $raja|
|    #raja|
|    .raja|

预期产量:

+---------+
|full_name|
+---------+
|    raja|
|    raja|
|    raja|     

val df2 = df1.select("full_name").withColumn("full_name",regexp_replace(col("full_name"), "^[$_]",  ""))

我的代码只删除了 $ 从第一张唱片开始。如何获得预期的输出?

1 回复 | 直到 5 年前

pheeleeppoo Mammad Yahyayev 5 年前

这是因为在正则表达式中,您只搜索 $ 字符串开头的符号。尝试添加要替换的其他符号,如下所示:

val df2 = df1.withColumn("full_name",regexp_replace(col("full_name"), "^[$#\\._]",  ""))

要获得预期的输出:

+---------+
|full_name|
+---------+
|     raja|
|     raja|
|     raja|
+---------+

推荐文章

srinath tripuraneni · {DataFrameWriter CSV到HDFS文件系统}不分区写入数据

2 年前

Calcutta · Google Colab中的Spark SQL在大数据上失败

2 年前

Palkin Jangra · 使用循环在Pyspark数组元素上和元素本身内迭代两次

2 年前

Doraemon · PySpark:使用不同值的字符串类型列创建聚合列

2 年前

amol visave · spark作业失败时会发生什么?

2 年前

Alex Jolly · 如何在另一个pyspark数据帧中查询开始时间和结束时间之间的日期时间

2 年前

chun · pyspark dataframe在s3中两次写入csv文件

2 年前

Mod_x · 如何将特定列的行标题更改为行标题,并在pySpark中生成矩阵?

2 年前

katty · 动态地将参数传递给scala中的函数

6 年前

Abhishek Choudhary · 如何更新数组列?

6 年前