partitioning.hours

Zaman damgalarının verileri saatlere bölmeye yönelik dönüşümü.

Uyarı

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

Sözdizimi

from pyspark.sql.functions import partitioning

partitioning.hours(col)

Parametreler

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

Örnekler

from pyspark.sql.functions import partitioning
df.writeTo("catalog.db.table").partitionedBy(
    partitioning.hours("ts")
).createOrReplace()