read_state_metadata função com valor de tabela

Aplica-se a: Databricks SQL Databricks Runtime 14.3 e superior

Retorna uma tabela com linhas que representam os metadados de um estado de consulta de streaming.

Uma função com valor de tabela para leitura de metadados de operadores com estado de consulta de streaming. Ele só suporta a execução como uma consulta em lote.

Sintaxe

read_state_metadata(path)

Argumentos

Esta função requer a invocação por parâmetro nomeado para as chaves de opção.

• path: Um STRING literal que contém o caminho para o local do ponto de verificação da consulta de streaming.

Devoluções

Uma tabela de metadados de estado tem o seguinte esquema. Todas as colunas NÃO são NULL.

• operatorId INT NOT NULL

  Um ID inteiro do operador de streaming com estado.

• operatorName STRING NOT NULL

  Nome do operador de streaming com estado.

• stateStoreName STRING NOT NULL

  Nome do armazenamento de estado do operador.

• numPartitions INT NOT NULL

  Número de partições do armazenamento de estado.

• minBatchId BIGINT NOT NULL

  O ID de lote mínimo disponível para consulta de estado. O valor pode ser inválido se a consulta de streaming que está a usar o ponto de verificação estiver a correr, pois isso faria com que a limpeza fosse executada.

• maxBatchId BIGINT NOT NULL

  O ID máximo de lote disponível para a consulta de estado. O valor pode ser inválido se a consulta de streaming que toma o ponto de verificação estiver em execução, pois a consulta confirmará outros lotes.

Exemplos

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

Artigos relacionados

• CREATE STREAMING TABLE
• read_kafka função com valor de tabela