一時ビュー

Pythonでビューを定義するには、 @temporary_viewデコレータを適用してから、マテリアライズドビューやストリーミング テーブルなどの他のクエリでビューを名前で参照します。 ビューの結果はクエリ時に計算されます。

注記

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

構文

Python

from pyspark import pipelines as dp

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

問題

パラメーター	Type	説明
function	function	必須。ユーザー定義のクエリから Apache Spark DataFrame またはストリーミング DataFrame を返す関数。
name	str	ビュー名。指定されていない場合は、デフォルトで関数名になります。名前は、パイプラインの対象となるカタログとスキーマ内で一意である必要があります。
comment	str	テーブルの説明。