Skip to content

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|
# +-------+---------------+

Примечания

  • Если n равно 0, возвращается пустая строка
  • Если n отрицательный, возвращается NULL
  • NULL значения возвращают NULL
  • Для создания строки из повторяющегося символа используйте lpad() или rpad()