regexp_replace

Nahraďte všechny podřetězce zadané řetězcové hodnoty, které odpovídají regexp, náhradou.

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

Syntaxe

from pyspark.sql import functions as dbf

dbf.regexp_replace(string=<string>, pattern=<pattern>, replacement=<replacement>)

Parametry

Parameter Typ Description
string pyspark.sql.Column nebo str název sloupce nebo sloupec obsahující řetězcovou hodnotu
pattern pyspark.sql.Column nebo str column object or str obsahující vzor regexp
replacement pyspark.sql.Column nebo str column object or str obsahující nahrazení

Examples

from pyspark.sql import functions as dbf
df = spark.createDataFrame(
[("100-200", r"(\d+)", "--")],
["str", "pattern", "replacement"]
)
df.select('*', dbf.regexp_replace('str', r'(\d+)', '--')).show()
df.select('*',
dbf.regexp_replace(dbf.col("str"), dbf.col("pattern"), dbf.col("replacement"))
).show()