replace

Reemplaza todas las repeticiones de search por replace.

Para obtener la función SQL de Databricks correspondiente, consulte replace function.

Syntax

from pyspark.databricks.sql import functions as dbf

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

Parámetros

Parámetro	Tipo	Description
src	pyspark.sql.Column o str	Columna de cadena que se va a reemplazar.
search	pyspark.sql.Column o str	Una columna de cadena, Si search no se encuentra en str, str se devuelve sin cambios.
replace	pyspark.sql.Column o str, optional	Una columna de cadena, si replace no se especifica o es una cadena vacía, nada reemplaza a la cadena que se quita de str.

Examples

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