visualização_temporária
Para definir uma view em Python, aplique o decorador @temporary_view
. Assim como o decorador @table
, você pode usar a visualização no pipeline declarativo LakeFlow para conjuntos de dados estáticos ou de transmissão.
O módulo dlt
mais antigo usava o decorador @view
para definir uma view temporária. Databricks recomenda usar o módulo pyspark.pipelines
(importado como dp
) e o decorador @temporary_view
para definir a visualização temporária.
A seguir está a sintaxe para definir visualizações com Python:
Sintaxe
from pyspark import pipelines as dp
@dp.view(
name="<name>",
comment="<comment>")
@dp.expect(...)
def <function-name>():
return (<query>)
Parâmetros
Parâmetro | Tipo | Descrição |
---|---|---|
função |
| Obrigatório. Uma função que retorna um Apache Spark DataFrame ou transmissão DataFrame de uma consulta definida pelo usuário. |
|
| O nome da tabela. Se não for fornecido, o padrão será o nome da função. |
|
| Uma descrição para a tabela. |