vista temporal

Para definir una vista en una canalización con Python, aplique el @temporary_view decorador y haga referencia a las vistas por nombre en otras consultas, incluidas las vistas materializadas y las tablas de streaming. Los resultados de la vista se calculan cuando se solicitan.

Nota:

El módulo anterior dlt usó el decorador @view para definir una vista temporal. Databricks recomienda usar el pyspark.pipelines módulo (importado como dp) y el @temporary_view decorador para definir vistas temporales.

Syntax

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
función	function	Obligatorio. Función que devuelve un dataframe de Apache Spark o un dataframe de streaming desde una consulta definida por el usuario.
name	str	Nombre de la vista. Si no se proporciona, el valor predeterminado es el nombre de la función. El nombre debe ser único dentro del catálogo y el esquema de destino de la canalización.
comment	str	Una descripción de la tabla.