Partilhar via

read_state_metadata tablefunção valorada

  • Artigo

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

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

Uma função de valor table para a leitura de metadados dos operadores com estado em consultas 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.

Devoluções

Uma table de metadados de estado tem o seguinte schema. Todos os columns NÃO são NULOS.

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