パイプラインSQL言語リファレンス

このセクションには、 Lakeflow Spark宣言型パイプラインSQLプログラミング インターフェイスの詳細が記載されています。

• LakeFlow Spark宣言型パイプラインSQLの使用に関する概念的な情報と概要については、 「 SQLを使用したLakeFlow Spark宣言型パイプライン コードの開発」を参照してください。
• Python APIについては、「 Lakeflow Spark宣言型パイプラインPython言語リファレンス」を参照してください。
• DatabricksのSQLの詳細については、 SQL言語リファレンスを参照してください。

SQL クエリで Python ユーザー定義関数 (UDF) を使用できますが、SQL ソース ファイルで呼び出す前に、これらの UDF を Python ファイルで定義する必要があります。「ユーザー定義のスカラー関数 - Python」を参照してください。

SQL文

これらのステートメントを使用して、SQL でパイプラインを操作します。

• AUTO CDC INTO
• CREATE FLOW
• CREATE MATERIALIZED VIEW
• CREATE STREAMING TABLE
• CREATE TEMPORARY VIEW
• CREATE VIEW

次のステートメントを使用してパイプラインを操作することもできますが、これらのステートメントはパイプライン内からではなくDatabricks SQLから実行する必要があります。 Databricks SQLを使用したデータウェアハウジングの開始」と「パイプライン データセットでのALTERステートメントの使用」を参照してください。

• ALTER STREAMING TABLE
• ALTER MATERIALIZED VIEW
• MATERIALIZED VIEWの説明