Referencia del lenguaje SQL para "Pipeline"

La interfaz de programación SQL de canalizaciones de Lakeflow define canalizaciones mediante instrucciones CREATE, CREATE FLOW y AUTO CDC INTO.

Puede usar funciones definidas por el usuario (UDF) de Python en las consultas SQL, pero debe definir estas UDF en archivos de Python antes de llamarlas en archivos de origen de SQL. Consulte Python funciones escalares definidas por el usuario (UDF).

Instrucciones SQL

Use estas instrucciones para trabajar con canalizaciones en SQL.

También puede usar las siguientes instrucciones para trabajar con canalizaciones, pero deben ejecutarse desde Databricks SQL, no desde una canalización. Consulte Introducción al almacenamiento de datos mediante Databricks SQL y Uso ALTER de instrucciones con conjuntos de datos de canalización.