replace

Заменяет все случаи search на replace.

Для соответствующей функции Databricks SQL смотрите функцию replace.

Синтаксис

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')]