dočasný pohled

Pokud chcete definovat zobrazení v potrubí pomocí Pythonu, použijte @temporary_view dekorátor a potom odkazujte na zobrazení podle názvu v jiných dotazech, včetně materializovaných zobrazení a streamovaných tabulek. Výsledky zobrazení se počítají při provádění dotazu.

Poznámka:

Starší dlt modul používal @view dekorátor k definování dočasného zobrazení. Databricks doporučuje používat pyspark.pipelines modul (importovaný jako dp) a @temporary_view dekorátor k definování dočasných zobrazení.

Syntaxe

from pyspark import pipelines as dp

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

Parametry

Parameter	Typ	Description
funkce	function	Povinné. Funkce, která vrací datový rámec Apache Spark nebo streamovaný datový rámec z uživatelem definovaného dotazu.
name	str	Název zobrazení. Pokud není zadaný, nastaví se výchozí hodnota názvu funkce. Název musí být jedinečný v rámci katalogu a schématu, k němuž je pipeline směrována.
comment	str	Popis tabulky.