Informations de référence sur le langage SQL de pipeline

L’interface de programmation SQL de Lakeflow Spark Declarative Pipelines permet de définir des pipelines à l’aide des instructions CREATE, CREATE FLOW et AUTO CDC INTO.

• Pour obtenir des informations conceptuelles et une vue d’ensemble de l’utilisation de Lakeflow Spark Declarative Pipelines SQL, consultez Développer du code pipelines déclaratifs Spark Lakeflow avec SQL.
• Pour plus d’informations sur l’API Python, consultez la référence du langage Python de Lakeflow Spark Declarative Pipelines.
• Pour plus d’informations sur SQL dans Databricks, consultez la référence du langage SQL.

Vous pouvez utiliser des fonctions définies par l’utilisateur Python dans vos requêtes SQL, mais vous devez définir ces fonctions définies par l’utilisateur dans les fichiers Python avant de les appeler dans des fichiers sources SQL. Voir Fonctions scalaires définies par l'utilisateur – Python.

Requêtes SQL

Utilisez ces instructions pour utiliser des pipelines dans SQL.

• AUTO CDC INTO
• CREATE FLOW
• CREATE MATERIALIZED VIEW
• CREATE STREAMING TABLE
• CRÉER UNE VUE TEMPORAIRE
• CREATE VIEW

Vous pouvez également utiliser les instructions suivantes pour travailler avec des pipelines, mais elles doivent être exécutées à partir de Databricks SQL, et non à partir d’un pipeline. Consultez Démarrage de l’entreposage de données à l’aide de Databricks SQL et ALTER.

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