read_state_metadata función con valores de tabla

Se aplica a: Databricks SQL Databricks Runtime 14.3 y versiones posteriores

Devuelve una tabla con filas que representan los metadatos de un estado de consulta de streaming.

Función con valores de tabla para leer metadatos de operadores con estado de consulta de streaming. Solo admite la ejecución como una consulta por lotes.

Sintaxis

read_state_metadata(path)

Argumentos

Esta función requiere la invocación de parámetros con nombre para las claves de opción.

• path: STRING literal con la ruta de acceso de la ubicación del punto de control de consulta de streaming.

Devoluciones

Una tabla de metadatos de estado tiene el esquema siguiente. Todas las columnas son NOT NULL.

• operatorId INT NOT NULL

  Identificador entero del operador de streaming con estado.

• operatorName STRING NOT NULL

  Nombre del operador de streaming con estado.

• stateStoreName STRING NOT NULL

  Nombre del almacén de estado del operador.

• numPartitions INT NOT NULL

  Número de particiones del almacén de estado.

• minBatchId BIGINT NOT NULL

  Identificador de lote mínimo disponible para el estado de consulta. El valor podría no ser válido si la consulta de streaming que tomase el punto de control se estuviera ejecutando, ya que haría que se ejecutara la limpieza.

• maxBatchId BIGINT NOT NULL

  Identificador de lote máximo disponible para el estado de la consulta. El valor podría no ser válido si la consulta de streaming que tomase el punto de control se estuviera ejecutando, ya que la consulta confirmaría más lotes.

Ejemplos

- Read state metadata from the checkpoint
> SELECT * FROM read_state_metadata('/checkpoint/path');

Artículos relacionados

• CREATE STREAMING TABLE
• Función con valores de tabla read_kafka