timestamp_diff

Kesir bölümünü keserek belirtilen birimlerdeki zaman damgaları arasındaki farkı alır.

Sözdizimi

from pyspark.sql import functions as dbf

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

Parametreler

Parametre Türü Description
unit literal string Bu, verilen zaman damgaları arasındaki farkın birimlerini gösterir. Desteklenen seçenekler şunlardır (büyük/küçük harfe duyarsız): "YIL", "ÇEYREK", "AY", "HAFTA", "GÜN", "SAAT", "DAKİkA", "SANIYE", "MILISANIYE" ve "MICROSECOND".
start pyspark.sql.Column veya str İfadenin içinden endTimestampçıkardığı zaman damgası.
end pyspark.sql.Column veya str İfadenin startTimestampçıkardığı zaman damgası.

İade

pyspark.sql.Column: zaman damgaları arasındaki fark.

Örnekler

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()