timestamp_add

Obtient la différence entre les horodatages dans les unités spécifiées en tronquant la partie fractionnaire.

Syntaxe

Python

from pyspark.sql import functions as dbf

dbf.timestamp_add(unit=<unit>, quantity=<quantity>, ts=<ts>)

parameter

parameter	Type	Description
unit	literal string	Ceci indique les unités de la différence entre les Timestamp donnés. Les options prises en charge sont (insensibles à la casse) : "YEAR", "QUARTER", "MONTH", "WEEK", "DAY", "HOUR", "MINUTE", "SECOND", "MILLISECOND" et "MICROSECOND".
quantity	pyspark.sql.Column OU str	Le nombre d'unités de temps que vous souhaitez ajouter.
ts	pyspark.sql.Column OU str	Un Timestamp auquel vous souhaitez ajouter.

parameter	Type	Description
unit	literal string	Ceci indique les unités de la différence entre les Timestamp donnés. Les options prises en charge sont (insensibles à la casse) : "YEAR", "QUARTER", "MONTH", "WEEK", "DAY", "HOUR", "MINUTE", "SECOND", "MILLISECOND" et "MICROSECOND".
quantity	pyspark.sql.Column OU str	Le nombre d'unités de temps que vous souhaitez ajouter.
ts	pyspark.sql.Column OU str	Un Timestamp auquel vous souhaitez ajouter.

Renvoie

pyspark.sql.Column: la différence entre les Timestamp.

Exemples

Python

import datetime
from pyspark.sql import functions as dbf
df = spark.createDataFrame(
[(datetime.datetime(2016, 3, 11, 9, 0, 7), 2),
(datetime.datetime(2024, 4, 2, 9, 0, 7), 3)], ['ts', 'quantity'])
df.select('*', dbf.timestamp_add('year', 'quantity', 'ts')).show()
df.select('*', dbf.timestamp_add('WEEK', dbf.lit(5), df.ts)).show()
df.select('*', dbf.timestamp_add('day', dbf.lit(-5), 'ts')).show()