Função com valor de tabela read_state_metadata

Aplica-se a: SQL do Databricks Databricks Runtime 14.3 e versões posteriores

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

Uma função com valor de tabela para ler metadados de operadores de consulta de streaming com estado. Ele só dá suporte à execução como uma consulta em lote.

Sintaxe

read_state_metadata(path)

Argumentos

Essa função requer invocação de parâmetro nomeada para as chaves de opção.

• path: Um literal STRING com o caminho do local do ponto de verificação da consulta de streaming.

Retornos

Uma tabela de metadados de estado tem o esquema a seguir. Todas as colunas são NOT NULL.

• operatorId INT NOT NULL

  Uma ID de inteiro do operador de streaming com estado.

• operatorName STRING NOT NULL

  Nome do operador de streaming com estado.

• stateStoreName STRING NOT NULL

  Nome do repositório de estado do operador.

• numPartitions INT NOT NULL

  Número de partições do repositório de estado.

• minBatchId BIGINT NOT NULL

  A ID mínima do lote disponível para o estado de consulta. O valor poderá ser inválido se a consulta de streaming que está executando o ponto de verificação estiver em execução, pois isso faria com que a limpeza fosse executada.

• maxBatchId BIGINT NOT NULL

  A ID máxima do lote disponível para consultar o estado. O valor poderá ser inválido se a consulta de streaming que está executando o ponto de verificação estiver em execução, pois a consulta confirmará mais 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