hours

Bölüm dönüştürme işlevi: Zaman damgalarının verileri saatlere bölmeye yönelik dönüşümü. Spark Connect'i destekler.

Uyarı

4.0.0'da kullanım dışı bırakıldı. Bunun yerine partitioning.hours kullanın.

Sözdizimi

from pyspark.sql import functions as dbf

dbf.hours(col=<col>)

Parametreler

Parametre Türü Description
col pyspark.sql.Column veya str Üzerinde çalışacak tarih veya zaman damgası sütununu hedefle.

İade

pyspark.sql.Column: Saatlere göre bölümlenmiş veriler.

Örnekler

df.writeTo("catalog.db.table").partitionedBy(
    hours("ts")
).createOrReplace()

Uyarı

Bu işlev yalnızca DataFrameWriterV2 yöntemiyle partitionedBy birlikte kullanılabilir.