替换

将所有 search 项都替换为 replace。

有关相应的 Databricks SQL 函数，请参阅 replace 函数。

Syntax

from pyspark.databricks.sql import functions as dbf

dbf.replace(src=<src>, search=<search>, replace=<replace>)

参数

参数	类型	Description
src	pyspark.sql.Column 或 str	要替换的字符串列。
search	pyspark.sql.Column 或 str	字符串列（如果未 search 在 中找到 str） str 将保持不变。
replace	pyspark.sql.Column 或 str, optional	字符串列，如果未 replace 指定或为空字符串，则不替换从中删除 str的字符串。

例子

df = spark.createDataFrame([("ABCabc", "abc", "DEF",)], ["a", "b", "c"])
df.select(replace(df.a, df.b, df.c).alias('r')).collect()

[Row(r='ABCDEF')]

df.select(replace(df.a, df.b).alias('r')).collect()

[Row(r='ABC')]