Lakeflow 管線的 SQL 程式設計介面使用 CREATE 陳述式、CREATE FLOW 和 AUTO CDC INTO 來定義管線。
- 關於使用 Lakeflow pipelines SQL 的概念性資訊及概述,請參閱 「Develop Lakeflow pipelines code with SQL」。
- 關於 Python API 的資訊,請參閱 Lakeflow pipelines Python 語言參考資料。
- 如需 Databricks 中 SQL 的詳細資訊,請參閱 SQL 語言參考。
您可以在 SQL 查詢中使用 Python 使用者定義函數 (UDF),但您必須先在 Python 檔案中定義這些 UDF,才能在 SQL 原始檔中呼叫它們。 參見 Python 標量使用者定義函數(UDF)。
SQL 陳述式
使用這些陳述式來處理 SQL 中的管線。
你也可以用以下語句來處理管線,但它們必須從 Databricks SQL 執行,不能在管線內執行。 請參閱「 使用 Databricks SQL 開始資料倉儲」以及 「使用管線資料集的陳述 ALTER 式」。