Catatan
Akses ke halaman ini memerlukan otorisasi. Anda dapat mencoba masuk atau mengubah direktori.
Akses ke halaman ini memerlukan otorisasi. Anda dapat mencoba mengubah direktori.
Fungsi transformasi partisi: Transformasi untuk tanda waktu menjadi data partisi menjadi jam. Mendukung Spark Connect.
Peringatan
Tidak digunakan lagi dalam 4.0.0. Gunakan partitioning.hours sebagai gantinya.
Syntax
from pyspark.sql import functions as dbf
dbf.hours(col=<col>)
Parameter-parameternya
| Pengaturan | Tipe | Description |
|---|---|---|
col |
pyspark.sql.Column atau str |
Kolom tanggal atau tanda waktu target untuk dikerjakan. |
Pengembalian Barang
pyspark.sql.Column: Data yang dipartisi berdasarkan jam.
Examples
df.writeTo("catalog.db.table").partitionedBy(
hours("ts")
).createOrReplace()
Nota
Fungsi ini hanya dapat digunakan dalam kombinasi dengan partitionedBy metode DataFrameWriterV2.