timestamp_add
Obtém a diferença entre os registros de data e hora nas unidades especificadas, truncando a parte fracionária.
Sintaxe
Python
from pyspark.databricks.sql import functions as dbf
dbf.timestamp_add(unit=<unit>, quantity=<quantity>, ts=<ts>)
Parâmetros
Parâmetro | Tipo | Descrição |
|---|---|---|
|
| Isso indica as unidades da diferença entre os registros de data e hora fornecidos. As opções suportadas são (sem distinção entre maiúsculas e minúsculas): "YEAR", "QUARTER", "MONTH", "WEEK", "DAY", "HOUR", "MINUTE", "SECOND", "MILLISECOND" e "MICROSECOND". |
|
| O número de unidades de tempo que você deseja adicionar. |
|
| Um registro de data e hora ao qual você deseja adicionar. |
Devoluções
pyspark.sql.Column: a diferença entre os registros de data e hora.
Exemplos
Python
import datetime
from pyspark.databricks.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()