ideiglenes nézet

Ha pythonos folyamat nézetét szeretné definiálni, alkalmazza a @temporary_view dekorátort, majd más lekérdezésekben név szerint hivatkozzon a nézetekre, beleértve a materializált nézeteket és a streamelési táblákat. A rendszer a lekérdezéskor kiszámítja a nézet eredményeit.

Megjegyzés:

A régebbi dlt modul a @view dekorátorral definiált egy ideiglenes nézetet. A Databricks azt javasolja, hogy az ideiglenes nézetek meghatározásához használja a pyspark.pipelines modult (importálva dp) és a @temporary_view dekorátort.

Szemantika

from pyspark import pipelines as dp

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

Paraméterek

Paraméter	Típus	Description
funkció	function	Szükséges. Olyan függvény, amely egy Apache Spark DataFrame-et ad vissza, vagy egy felhasználó által definiált lekérdezésből streameli a DataFrame-et.
name	str	A nézet neve. Ha nincs megadva, alapértelmezés szerint a függvény neve lesz. A névnek egyedinek kell lennie a katalógusban és a folyamat által megcélzott sémában.
comment	str	A táblázat leírása.