Referensi bahasa Pipeline SQL

Antarmuka pemrograman SQL untuk pipeline Lakeflow mendefinisikan pipeline dengan pernyataan CREATE, CREATE FLOW, dan AUTO CDC INTO.

• Untuk informasi konseptual dan gambaran umum penggunaan alur Lakeflow SQL, lihat Mengembangkan kode alur Lakeflow dengan SQL.
• Untuk informasi tentang API Python, lihat referensi bahasa Python untuk pipeline Lakeflow.
• Untuk informasi selengkapnya tentang SQL di Databricks, lihat Referensi bahasa SQL.

Anda dapat menggunakan fungsi yang ditentukan pengguna (UDF) Python dalam kueri SQL Anda, tetapi Anda harus menentukan UDF ini dalam file Python sebelum memanggilnya dalam file sumber SQL. Lihat fungsi skalar Python yang ditentukan pengguna (UDF).

Pernyataan SQL

Gunakan pernyataan ini untuk bekerja dengan alur di SQL.

• CDC OTOMATIS KE
• BUAT ALUR
• CREATE MATERIALIZED VIEW
• CREATE STREAMING TABLE
• BUAT TAMPILAN SEMENTARA
• CREATE VIEW

Anda juga dapat menggunakan pernyataan berikut untuk bekerja dengan alur, tetapi harus dijalankan dari Databricks SQL, bukan dari dalam alur. Lihat Mulai menggunakan pergudangan data menggunakan Databricks SQL, dan Menggunakan ALTER pernyataan dengan himpunan data alur.

• ALTER STREAMING TABLE
• ALTER MATERIALIZED VIEW
• EXPLAIN CREATE MATERIALIZED VIEW