Compartir a través de

read_statestore función con valores de tabla

  • Artículo

Se aplica a: casilla marcada como sí Databricks SQL casilla marcada como Sí Databricks Runtime 14.3 y versiones posteriores

Importante

Esta característica está en versión preliminar pública.

Una función con valores de tabla para leer registros del almacén de estado de consultas de streaming. La relación devuelta solo admite la ejecución como una consulta por lotes.

Sintaxis

read_statestore ( path [, option_key => option_value ] [ ... ] )

Argumentos

read_statestore requiere la invocación de parámetros con nombre para sus parámetros opcionales.

  • path: un valor STRING literal. Ruta de acceso de la ubicación del punto de control de consulta de streaming.
  • option_key: nombre de la opción que se va a configurar. Debe usar el acento grave (`) para las opciones que contienen puntos (.).
  • option_value: una expresión constante para establecer la opción. Acepta literales y funciones escalares.

Los elementos option_value no distinguen mayúsculas de minúsculas.

option_key Tipo Valor predeterminado Descripción
batchId BIGINT Id. de lote más reciente Representa el lote de destino del que se va a leer. Esta opción se usa cuando los usuarios quieren realizar viajes en el tiempo. El lote debe confirmarse, pero no se debe limpiar todavía.
OperatorId BIGINT 0 Representa el operador de destino del que se va a leer. Esta opción se usa cuando la consulta usa varios operadores con estado.
storeName STRING 'DEFAULT' Representa el lado de destino del que se va a leer. Esta opción se usa cuando los usuarios quieren leer el estado de la combinación de transmisión con transmisión.
joinSide STRING 'None' Representa el lado de destino del que se va a leer. Esta opción se usa cuando los usuarios quieren leer el estado de la combinación de transmisión con transmisión. Uno de estos valores: 'Left', 'Right' o 'None'.

Devoluciones

La función devuelve un conjunto de resultados con las columnas siguientes.

Nota:

Las columnas anidadas para clave y valor dependen en gran medida del esquema de entrada del operador con estado y del tipo de operador.

Nombre Tipo de datos Nullable Estándar Descripción
id STRUCT No Fila de clave del operador con estado almacenado en el punto de comprobación de estado.
value STRUCT Sí Fila de valor del operador con estado almacenado en el punto de comprobación de estado.
partition_id INTEGER No Partición que contiene el registro.
shardId STRING No Identificador único de la partición desde la que se leyeron los datos.
sequenceNumber BIGINT No Identificador único del registro dentro de su partición.
approximateArrivalTimestamp TIMESTAMP No La hora aproximada en la que se insertó el registro en la secuencia.

Ejemplos

- Read from state
> SELECT * FROM read_statestore('/checkpoint/path');

– Read from state with storeName option
> SELECT * FROM read_statestore(
      '/checkpoint/path',
      operatorId => 0,
      batchId => 2,
      storeName => 'default'
  );

– Read from state with joinSide option

> SELECT * FROM read_statestore(
      '/checkpoint/path',
      joinSide => 'left'
  );