Partilhar via

read_state_metadata função com valor de tabela

  • Artigo

Aplica-se a:check marked yes 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 de parâmetro nomeado para as teclas de opção.

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

Devolve

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 monitoração de 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 o estado de consulta. O valor pode ser inválido se a consulta de streaming que toma o ponto de verificação estiver em execução, pois isso causaria a execução da limpeza.

  • maxBatchId BIGINT NOT NULL

    O ID de lote máximo disponível para o estado de consulta. 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');