串流 SQL 語言參考

Lakeflow 管線的 SQL 程式設計介面使用 CREATE 陳述式、CREATE FLOWAUTO CDC INTO 來定義管線。

您可以在 SQL 查詢中使用 Python 使用者定義函數 (UDF),但您必須先在 Python 檔案中定義這些 UDF,才能在 SQL 原始檔中呼叫它們。 參見 Python 標量使用者定義函數(UDF)。

SQL 陳述式

使用這些陳述式來處理 SQL 中的管線。

你也可以用以下語句來處理管線,但它們必須從 Databricks SQL 執行,不能在管線內執行。 請參閱「 使用 Databricks SQL 開始資料倉儲」以及 「使用管線資料集的陳述 ALTER」。