current_snapshot_version Función

Devuelve la fila de versión seleccionada por la cláusula del WITH VERSION (...) flujo adjunto para la instantánea que se está procesando.

Esta función solo está disponible dentro de la FROM SNAPSHOT (...) cláusula de un AUTO CDC ... FROM SNAPSHOT flujo.

Syntax

current_snapshot_version()

Argumentos

Esta función no toma ningún argumento.

Devoluciones

Una relación de una sola columna con el mismo nombre y tipo de columna que la consulta de versión del flujo que encierra, que contiene exactamente 1 fila. La fila contiene la versión seleccionada para la iteración actual de procesamiento de instantáneas.

current_snapshot_version() se evalúa solo después de que la consulta de versión devuelve 1 fila. Si la consulta de versión devuelve 0 filas, el motor no ejecuta la consulta de instantánea y termina el procesamiento del flujo durante esa actualización de la canalización.

Examples

El siguiente flujo se utiliza current_snapshot_version() para leer el archivo seleccionado por la WITH VERSION (...) cláusula. La versión es de una sola STRUCT columna, por lo que sus campos se acceden con notación de puntos:

CREATE FLOW orders_cdc
  AS AUTO CDC INTO orders
  FROM SNAPSHOT (
    SELECT *
    FROM read_files('/Volumes/catalog/schema/landing/orders/', format => 'json')
    WHERE _metadata.file_path = (SELECT version.path FROM current_snapshot_version())
  )
  WITH VERSION (...)
  KEYS (order_id);

Errors

current_snapshot_version() está disponible solo dentro de la FROM SNAPSHOT (...) cláusula de un AUTO CDC ... FROM SNAPSHOT flujo que declara una WITH VERSION (...) cláusula. En cualquier otro lugar, Spark resuelve el nombre como una función ordinaria de valor en tabla. Como no está definida tal función, eleva UNRESOLVABLE_TABLE_VALUED_FUNCTION (SQLSTATE 42883).

Funciones relacionadas

• last_snapshot_version Función