tijdelijke_view

Als u een weergave in een pijplijn met Python wilt definiëren, past u de @temporary_view decorator toe en verwijst u vervolgens naar weergaven op naam in andere query's, waaronder gerealiseerde weergaven en streamingtabellen. De resultaten van de weergave worden berekend wanneer er query's worden uitgevoerd.

Opmerking

De oudere dlt module heeft de @view decorator gebruikt om een tijdelijke weergave te definiëren. Databricks raadt aan om de pyspark.pipelines module (geïmporteerd als dp) en de @temporary_view decorator te gebruiken om tijdelijke weergaven te definiëren.

Syntaxis

from pyspark import pipelines as dp

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

Parameterwaarden

Kenmerk	Typologie	Description
functie	function	Verplicht. Een functie die een Apache Spark DataFrame retourneert of DataFrame streamt vanuit een door de gebruiker gedefinieerde query.
name	str	De weergavenaam. Als deze niet is opgegeven, wordt standaard de functienaam gebruikt. De naam moet uniek zijn binnen de catalogus en het schema waarop de pijplijn is gericht.
comment	str	Een beschrijving voor de tabel.