visualização_temporária
Para definir uma view em Python, aplique o decorador @temporary_view e, em seguida, faça referência à visão pelo nome em outras consultas, incluindo visões materializadas e tabelas de transmissão. Os resultados da view são calculados quando a consulta é feita.
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.
Sintaxe
from pyspark import pipelines as dp
@dp.temporary_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 view . Caso não seja fornecido, será utilizado o nome da função por padrão. O nome deve ser único dentro do catálogo e do esquema visados pelo pipeline. |
|
| Uma descrição para a tabela. |