若要在 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 |
表的说明。 |