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.
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.