Lakeflow 管道 SQL 编程接口使用 CREATE 语句、CREATE FLOW 和 AUTO CDC INTO 来定义管道。
- 有关使用 Lakeflow 管道 SQL 的概念信息和概述，请参阅 使用 SQL 开发 Lakeflow 管道代码。
- 有关 Python API 的信息，请参阅 Lakeflow 管道Python语言参考。
- 有关 Databricks 中的 SQL 的详细信息，请参阅 SQL 语言参考。
可以在 SQL 查询中使用 Python 用户定义的函数（UDF），但在 SQL 源文件中调用这些 UDF 之前，必须在 Python 文件中定义这些 UDF。 请参阅Python标量用户定义函数（UDF）。
SQL 语句
使用这些语句处理 SQL 中的管道。
- 自动 CDC INTO
- CREATE FLOW
- CREATE MATERIALIZED VIEW
- CREATE STREAMING TABLE
- CREATE TABLE ...FLOW
- 创建临时视图
- CREATE VIEW
还可以使用以下语句来处理管道，但它们必须从 Databricks SQL 运行，而不是从管道内部运行。 请参阅 使用 Databricks SQL 的数据仓库入门，以及将ALTER语句与管道数据集配合使用。