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.
Untuk menentukan tampilan dalam alur dengan Python, terapkan @temporary_view dekorator, lalu referensi tampilan berdasarkan nama dalam kueri lain, termasuk tampilan materialisasi dan tabel streaming. Hasil tampilan dihitung saat dikueri.
Nota
Modul lama dlt menggunakan @view decorator untuk mendefinisikan tampilan sementara. Databricks merekomendasikan penggunaan pyspark.pipelines modul (diimpor sebagai dp) dan @temporary_view dekorator untuk menentukan tampilan sementara.
Syntax
from pyspark import pipelines as dp
@dp.temporary_view(
name="<name>",
comment="<comment>")
@dp.expect(...)
def <function-name>():
return (<query>)
Parameter-parameternya
| Pengaturan | Tipe | Description |
|---|---|---|
| fungsi | function |
Dibutuhkan. Suatu fungsi yang menghasilkan DataFrame Apache Spark atau streaming DataFrame dari kueri yang ditentukan pengguna. |
name |
str |
Nama tampilan. Jika tidak disediakan, akan otomatis menggunakan nama fungsi. Nama harus unik dalam katalog dan skema yang ditargetkan oleh alur proses. |
comment |
str |
Deskripsi untuk tabel. |