重复字符串列 n 次,并将其作为新字符串列返回。
有关相应的 Databricks SQL 函数,请参阅 repeat 函数。
Syntax
from pyspark.databricks.sql import functions as dbf
dbf.repeat(col=<col>, n=<n>)
参数
| 参数 | 类型 | Description |
|---|---|---|
col |
pyspark.sql.Column 或 str |
要处理的目标列。 |
n |
pyspark.sql.Column 或 str 或 int |
重复值的次数。 |
退货
pyspark.sql.Column:具有重复值的字符串。
例子
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('ab',)], ['s',])
df.select("*", dbf.repeat("s", 3)).show()
df.select("*", dbf.repeat(df.s, dbf.lit(4))).show()
df = spark.createDataFrame([('ab', 5,), ('abc', 6,)], ['s', 't'])
df.select("*", dbf.repeat("s", "t")).show()