Pipeline SQL language reference

The Lakeflow Spark Declarative Pipelines SQL programming interface defines pipelines with CREATE statements, CREATE FLOW, and AUTO CDC INTO.

You can use Python user-defined functions (UDFs) in your SQL queries, but you must define these UDFs in Python files before calling them in SQL source files. See User-defined scalar functions - Python.

SQL statements

Use these statements to work with pipelines in SQL.

You can also use the following statements to work with pipelines, but they must be run from Databricks SQL, not from within a pipeline. See Get started with data warehousing using Databricks SQL, and Use ALTER statements with pipeline datasets.