SQL-språkreferens för pipeline

SQL-programmeringsgränssnittet för Lakeflow Spark Declarative Pipelines definierar pipelines med CREATE-satser, CREATE FLOW och AUTO CDC INTO.

• Konceptuell information och en översikt över hur du använder Lakeflow Spark Deklarativa pipelines SQL finns i Utveckla Lakeflow Spark Deklarativa pipelines-kod med SQL.
• Information om Python API:et finns i Python-språkreferensen för Lakeflow Spark deklarativa pipelines.
• Mer information om SQL i Databricks finns i SQL-språkreferens.

Du kan använda användardefinierade Python-funktioner (UDF: er) i dina SQL-frågor, men du måste definiera dessa UDF:er i Python-filer innan du anropar dem i SQL-källfiler. Se Användardefinierade skalärfunktioner – Python.

SQL-instruktioner

Använd dessa instruktioner för att arbeta med pipelines i SQL.

• AUTO CDC INTO
• SKAPA FLÖDE
• CREATE MATERIALIZED VIEW
• CREATE STREAMING TABLE
• SKAPA TILLFÄLLIG VY
• CREATE VIEW

Du kan också använda följande instruktioner för att arbeta med pipelines, men de måste köras från Databricks SQL, inte från en pipeline. Se Kom igång med datalagerhantering med Databricks SQL och Använd ALTER satser med pipelinedatauppsättningar.

• ALTER STREAMING TABLE
• ALTER MATERIALIZED VIEW
• EXPLAIN CREATE MATERIALIZED VIEW