Compartilhar via

visualização_temporária

Para definir uma visão em um pipeline com Python, aplique o decorador @temporary_view e, em seguida, referencie visões por nome em outras consultas, incluindo visões materializadas e tabelas de streaming. Os resultados da visualização são calculados ao serem consultados.

Observação

O módulo mais antigo dlt usou o @view decorador para definir uma exibição temporária. O Databricks recomenda usar o pyspark.pipelines módulo (importado como dp) e o @temporary_view decorador para definir exibições temporárias.

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 Description
função function Obrigatório Uma função que retorna um DataFrame do Apache Spark ou um DataFrame de streaming a partir de uma consulta personalizada pelo usuário.
name str O nome da exibição. Se não for fornecido, o padrão será o nome da função. O nome deve ser único no catálogo e no esquema direcionados pelo pipeline.
comment str Uma descrição da tabela.
  • Last updated on