管道 SQL 语言参考

Lakeflow 管道 SQL 编程接口使用 CREATE 语句、CREATE FLOWAUTO CDC INTO 来定义管道。

可以在 SQL 查询中使用 Python 用户定义的函数(UDF),但在 SQL 源文件中调用这些 UDF 之前,必须在 Python 文件中定义这些 UDF。 请参阅Python标量用户定义函数(UDF)。

SQL 语句

使用这些语句处理 SQL 中的管道。

还可以使用以下语句来处理管道,但它们必须从 Databricks SQL 运行,而不是从管道内部运行。 请参阅 使用 Databricks SQL 的数据仓库入门,以及ALTER语句与管道数据集配合使用