date_add
Renvoie la date qui est days jours après start. Si days est une valeur négative, alors ce nombre de jours sera déduit de start.
Pour la fonction Databricks SQL correspondante, consultez fonctiondate_add (jours).
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.date_add(start=<start>, days=<days>)
parameter
parameter | Type | Description |
|---|---|---|
|
| colonne de date sur laquelle travailler. |
|
| Combien de jours après la date donnée à calculer. Accepte également les valeurs négatives pour calculer en remontant le temps. |
Renvoie
pyspark.sql.Column: une date après/avant un nombre de jours donné.
Exemples
Python
from pyspark.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()