Referência da linguagem SQL de pipeline
A interface de programação SQL de Lakeflow pipelines define pipelines com instruções CREATE, CREATE FLOW e AUTO CDC INTO.
- Para informações conceituais e uma visão geral de como usar o SQL para LakeFlow Pipelines, consulte Desenvolver código SQL para LakeFlow Pipelines.
- Para obter informações sobre a API Python, consulte a referência da linguagem Python de Lakeflow Pipelines.
- Para mais informações sobre SQL no Databricks, consulte Referência da linguagemSQL.
Você pode usar funções definidas pelo usuário (UDFs) do Python em suas queries SQL, mas deve definir essas UDFs em arquivos Python antes de invocá-las em arquivos de origem SQL. Consulte funções escalares definidas pelo usuário (UDFs) do Python.
Instruções SQL
Utilize estas instruções para trabalhar com pipelines em SQL.
- AUTO CDC EM
- CRIAR FLUXO
- CREATE MATERIALIZED VIEW
- CREATE STREAMING TABLE
- CREATE TABLE ... FLOW
- CRIAR VISUALIZAÇÃO TEMPORÁRIA
- CREATE VIEW
Você também pode usar as seguintes instruções para trabalhar com pipelines, mas elas devem ser executadas a partir do Databricks SQL, e não de dentro de um pipeline. Consulte Introdução ao data warehousing usando Databricks SQL e Use instruções ALTER com conjunto de dados pipeline.