次の方法で共有


置換

出現するすべての searchreplace で置き換えます。

対応する Databricks SQL 関数については、 replace 関数を参照してください。

構文

from pyspark.databricks.sql import functions as dbf

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

パラメーター

パラメーター タイプ Description
src pyspark.sql.Column または str 置換する文字列の列。
search pyspark.sql.Column または str 文字列の列。strsearchが見つからない場合、strは変更されずに返されます。
replace pyspark.sql.Column または str, optional 文字列の列。 replace が指定されていないか、空の文字列である場合、 strから削除された文字列は何も置き換えません。

例示

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