repeat(col, n)
Описание
Функция repeat()
повторяет строку указанное количество раз.
Параметры
col
: Column - столбец со строками для повторенияn
: Integer - количество повторений
Возвращаемое значение
String - строка, повторенная указанное количество раз
Пример использования
from pyspark.sql.functions import repeat
from pyspark.sql import SparkSession
# Создаем SparkSession
spark = SparkSession.builder.appName("repeat_example").getOrCreate()
# Создаем DataFrame
data = [
("Hello"),
("Spark"),
("PySpark")
]
df = spark.createDataFrame(data, ["text"])
# Повторяем строки 3 раза
result = df.select(
"text",
repeat("text", 3).alias("repeated")
).show()
# Результат:
# +-------+---------------+
# |text |repeated |
# +-------+---------------+
# |Hello |HelloHelloHello|
# |Spark |SparkSparkSpark|
# |PySpark|PySparkPySparkPySpark|
# +-------+---------------+