通过


dateadd

返回日期,该日期为 daysstart几天。 如果 days 为负值,则将从中扣除 start这些天数。

有关相应的 Databricks SQL 函数,请参阅 dateadd 函数

Syntax

from pyspark.databricks.sql import functions as dbf

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

参数

参数 类型 Description
start pyspark.sql.Columnstr 要处理的日期列。
days pyspark.sql.Columnstrint 要计算给定日期后的天数。 接受负值,并及时计算向后计算。

退货

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()