time_trunc

öğesine kesilmiş timedöndürürunit.

Sözdizimi

from pyspark.sql import functions as dbf

dbf.time_trunc(unit=<unit>, time=<time>)

Parametreler

Parametre Türü Description
unit pyspark.sql.Column veya str Zamanı kesecek birim. Desteklenen birimler şunlardır: "HOUR", "MINUTE", "SECOND", "MILISECOND" ve "MICROSECOND". Birim büyük/küçük harfe duyarlı değildir.
time pyspark.sql.Column veya str Kesme zamanı.

İade

pyspark.sql.Column: Belirtilen birime kesilmiş bir süre.

Örnekler

from pyspark.sql import functions as dbf
df = spark.createDataFrame(
[("HOUR", "13:08:15")],
['unit', 'time']).withColumn("time", dbf.col("time").cast("time"))
df.select('*', dbf.time_trunc('unit', 'time')).show()