replace

Sostituire tutte le occorrenze di search con replace.

Per la funzione SQL di Databricks corrispondente, vedere replace funzione.

Sintassi

from pyspark.databricks.sql import functions as dbf

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

Parametri

Parametro	TIPO	Description
src	pyspark.sql.Column o str	Colonna di stringa da sostituire.
search	pyspark.sql.Column o str	Una colonna di stringa, Se search non viene trovata in str, str viene restituita invariata.
replace	pyspark.sql.Column o str, optional	Una colonna di stringa, se replace non è specificata o è una stringa vuota, nulla sostituisce la stringa rimossa da str.

Esempi

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