临时视图

若要在 Python 中定义视图,请应用 @temporary_view 修饰器,然后在其他查询中按名称引用视图,包括具体化视图和流式处理表。 查询时会计算视图的结果。

注释

较旧的 dlt 模块使用 @view 修饰器来定义临时视图。 Databricks 建议使用 pyspark.pipelines 模块(导入为) dp@temporary_view 修饰器来定义临时视图。

Syntax

from pyspark import pipelines as dp

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

参数

参数 类型 Description
函数 function 必填。 从用户定义的查询返回 Apache Spark 数据帧或流数据帧的函数。
name str 视图名称。 如果未提供,则默认为函数名称。 该名称在管道的目标目录和架构中必须是唯一的。
comment str 表的说明。