Dela via

temporary_view

Om du vill definiera en vy i Python använder du dekoratören @temporary_view och refererar sedan till vyer efter namn i andra frågor, inklusive materialiserade vyer och strömmande tabeller. Resultatet av vyn beräknas när den frågas.

Anmärkning

Den äldre dlt modulen använde dekoratören @view för att definiera en tillfällig vy. Databricks rekommenderar att du använder modulen pyspark.pipelines (importerad som dp) och dekoratören @temporary_view för att definiera tillfälliga vyer.

Syntax

from pyspark import pipelines as dp

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

Parameterar

Parameter Typ Description
funktion function Obligatoriskt. En funktion som returnerar en Apache Spark DataFrame eller strömmande DataFrame från en användardefinierad fråga.
name str Visningsnamnet. Om det inte anges används funktionsnamnet som standard. Namnet måste vara unikt i katalogen och schemat som pipelinen är inriktad på.
comment str En beskrivning av tabellen.