如何在PySpark中替换或删除特定角色

smdnsysy  于 2022-11-01  发布在  Spark
关注(0)|答案(1)|浏览(732)

{"header":{"type":"auto_translation","ret_code":"NullPointerException","time_cost":2640.0,"request_id":"9d4a7e3a59bd11ed9ba95b34174e380d"}}

pdtvr36n

pdtvr36n1#

如果你确定你永远不会遇到“;'在数据中以任何函数方式指定值,则可以使用以下方法:

import pyspark.sql.functions as F
df = input_df.withColumn('LastName', F.regexp_replace('LastName', '', ';'))

regexp_replace docs

相关问题