nahradit

Nahradí všechny výskyty search za replace.

Odpovídající funkci SQL Databricks vizte funkcereplace.

Syntaxe

from pyspark.sql import functions as dbf

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

Parametry

Parameter	Typ	Description
src	pyspark.sql.Column nebo str	Sloupec řetězce, který se má nahradit.
search	pyspark.sql.Column nebo str	Sloupec řetězce, Pokud search není nalezen v str, str je vrácen beze změny.
replace	pyspark.sql.Column nebo str, optional	Sloupec řetězce, Pokud replace není zadán nebo je prázdný řetězec, nic nenahrazuje řetězec, který je odebrán z 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')]