Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
öğ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()