一時ビュー

Python でビューを定義するには、 @temporary_view デコレータを適用します。@table デコレーターと同様に、Lakeflow 宣言型パイプラインのビューを静的データセットまたはストリーミング データセットに使用できます。

注記

古いdltモジュールでは、 @viewデコレータを使用して一時ビューを定義していました。Databricks では、一時ビューを定義するためにpyspark.pipelinesモジュール ( dpとしてインポート) と@temporary_viewデコレータを使用することをお勧めします。

以下は、Python でビューを定義するための構文です。

構文

Python

from pyspark import pipelines as dp

@dp.view(
  name="<name>",
  comment="<comment>")
@dp.expect(...)
def <function-name>():
    return (<query>)

問題

パラメーター	Type	説明
function	function	必須。ユーザー定義のクエリから Apache Spark DataFrame またはストリーミング DataFrame を返す関数。
name	str	テーブル名。指定されていない場合は、デフォルトで関数名になります。
comment	str	テーブルの説明。