Compartilhar via

Função com valor de tabela read_state_metadata

  • Artigo

Aplica-se a: verificação marcada como sim SQL do Databricks verificação marcada como sim 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');