Поделиться через


date_add

Возвращает дату, которая через days несколько дней.start Если days отрицательное значение, то эти дни будут вычитаться из start.

Соответствующая функция Databricks SQL см. в разделе date_add (дни).

Синтаксис

from pyspark.databricks.sql import functions as dbf

dbf.date_add(start=<start>, days=<days>)

Параметры

Параметр Тип Description
start pyspark.sql.Column или str Столбец даты для работы.
days pyspark.sql.Column или str или int сколько дней после заданной даты вычисления. Принимает отрицательное значение, а также вычисляет обратное время.

Возвраты

pyspark.sql.Column: дата после или до заданного числа дней.

Примеры

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('2015-04-08', 2,)], 'struct<dt:string,a:int>')
df.select('*', dbf.date_add(df.dt, 1)).show()
df.select('*', dbf.date_add('dt', 'a')).show()
df.select('*', dbf.date_add('dt', dbf.lit(-1))).show()