Compartir a través de

read_state_metadata 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

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');