Share via

read_state_metadata funzione con valori di tabella

  • Articolo

Si applica a:check marked yes Databricks Runtime 14.3 e versioni successive

Restituisce una tabella con righe che rappresentano i metadati di uno stato di query di streaming.

Funzione con valori di tabella per la lettura dei metadati degli operatori con stato di query di streaming. Supporta solo l'esecuzione come query batch.

Sintassi

read_state_metadata(path)

Argomenti

Questa funzione richiede la chiamata di parametri denominati per le chiavi di opzione.

  • path: valore STRING letterale con il percorso del checkpoint della query di streaming.

Valori restituiti

Una tabella di metadati di stato ha lo schema seguente. Tutte le colonne non sono NULL.

  • operatorId INT NOT NULL

    ID intero dell'operatore di streaming con stato.

  • operatorName STRING NOT NULL

    Nome dell'operatore di streaming con stato.

  • stateStoreName STRING NOT NULL

    Nome dell'archivio di stato dell'operatore.

  • numPartitions INT NOT NULL

    Numero di partizioni dell'archivio stati.

  • minBatchId BIGINT NOT NULL

    ID batch minimo disponibile per lo stato di query. Il valore potrebbe non essere valido se la query di streaming che accetta il checkpoint è in esecuzione, perché causerebbe l'esecuzione della pulizia.

  • maxBatchId BIGINT NOT NULL

    ID batch massimo disponibile per lo stato di query. Il valore potrebbe non essere valido se la query di streaming che accetta il checkpoint è in esecuzione, perché la query eseguirà il commit di altri batch.

Esempi

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