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


Dateadd

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

Для соответствующей функции Databricks SQL смотрите функцию dateadd.

Синтаксис

from pyspark.databricks.sql import functions as dbf

dbf.dateadd(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.dateadd(df.dt, 1)).show()
df.select('*', dbf.dateadd('dt', 'a')).show()
df.select('*', dbf.dateadd('dt', dbf.lit(-1))).show()