Dateadd

Vrátí datum, které je days po startdnech . Pokud days je záporná hodnota, odečtou se tyto dny od start.

Odpovídající funkci SQL Databricks vizte funkcedateadd.

Syntaxe

from pyspark.sql import functions as dbf

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

Parametry

Parameter Typ Description
start pyspark.sql.Column nebo str sloupec kalendářního data, na který se má pracovat.
days pyspark.sql.Column nebo str nebo int kolik dní po daném datu se má vypočítat. Přijímá také zápornou hodnotu k výpočtu zpětného časového limitu.

Návraty

pyspark.sql.Column: datum po/před daným počtem dní.

Examples

from pyspark.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()