timestamp_diff

Získá rozdíl mezi časovými razítky v zadaných jednotkách zkrácením části zlomku.

Syntaxe

from pyspark.sql import functions as dbf

dbf.timestamp_diff(unit=<unit>, start=<start>, end=<end>)

Parametry

Parameter	Typ	Description
unit	literal string	To označuje jednotky rozdílu mezi danými časovými razítky. Podporované možnosti jsou (nerozlišují malá a velká písmena): YEAR, QUARTER(ČTVRTLETÍ), MONTH (MĚSÍC), WEEK (TÝDEN), DAY (DEN), HOUR (HODINA), MINUTE (MINUTA), SECOND (SEKUNDA), MILLISECOND (MILISEKUND) a MICROSECOND (MIKROSECOND).
start	pyspark.sql.Column nebo str	Časové razítko, které výraz odečte od endTimestamp.
end	pyspark.sql.Column nebo str	Časové razítko, ze kterého výraz odečte startTimestamp.

Návraty

pyspark.sql.Column: rozdíl mezi časovými razítky.

Examples

import datetime
from pyspark.sql import functions as dbf
df = spark.createDataFrame(
[(datetime.datetime(2016, 3, 11, 9, 0, 7), datetime.datetime(2024, 4, 2, 9, 0, 7))],
['ts1', 'ts2'])
df.select('*', dbf.timestamp_diff('year', 'ts1', 'ts2')).show()
df.select('*', dbf.timestamp_diff('WEEK', 'ts1', 'ts2')).show()
df.select('*', dbf.timestamp_diff('day', df.ts2, df.ts1)).show()