replace

Diese Funktion ersetzt alle Vorkommen von search durch replace.

Die entsprechende Databricks SQL-Funktion finden Sie unter replace Funktion.

Syntax

from pyspark.databricks.sql import functions as dbf

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

Die Parameter

Parameter	Typ	Description
src	pyspark.sql.Column oder str	Eine Spalte der zu ersetzenden Zeichenfolge.
search	pyspark.sql.Column oder str	Eine Spalte mit Zeichenfolge, wenn search nicht strgefunden wird, str wird unverändert zurückgegeben.
replace	pyspark.sql.Column oder str, optional	Eine Spalte mit Zeichenfolge, wenn replace nicht angegeben oder eine leere Zeichenfolge ist, ersetzt nichts die Zeichenfolge, aus strder entfernt wird.

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