パイプラインSQL言語リファレンス
Lakeflow pipelinesのSQLプログラミングインターフェースは、CREATEステートメント、CREATE FLOW、およびAUTO CDC INTOを使用してパイプラインを定義します。
- LakeFlow Pipelines SQLの概念情報と使用の概要については、「SQLを使用したLakeFlow Pipelinesコードの開発」を参照してください。
- Python APIに関する情報については、LakeFlow Pipelines Python言語リファレンスをご覧ください。
- DatabricksのSQLの詳細については、 SQL言語リファレンスを参照してください。
SQL クエリーで Python ユーザー定義関数 (UDF) を使用できますが、SQL ソース ファイルで呼び出す前に、これらの UDF を Python ファイルで定義する必要があります。Python スカラー ユーザー定義関数 (UDF) を参照してください。
SQL文
これらのステートメントを使用して、SQL でパイプラインを操作します。
- AUTO CDC INTO
- CREATE FLOW
- CREATE MATERIALIZED VIEW
- CREATE STREAMING TABLE
- CREATE TEMPORARY VIEW
- CREATE VIEW
次のステートメントを使用してパイプラインを操作することもできますが、これらのステートメントはパイプライン内からではなくDatabricks SQLから実行する必要があります。 Databricks SQLを使用したデータウェアハウジングの開始」と「パイプライン データセットでのALTERステートメントの使用」を参照してください。