返回日期,该日期为 days 后 start几天。 如果 days 为负值,则将从中扣除 start这些天数。
有关相应的 Databricks SQL 函数,请参阅 dateadd 函数。
Syntax
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()