Dela via

read_state_metadata tabellvärdesfunktion

  • Artikel

Gäller för:markerad ja Databricks SQL markerad ja Databricks Runtime 14.3 och senare

Returnerar en tabell med rader som representerar metadata för ett strömmande frågetillstånd.

En tabellvärdefunktion för att läsa metadata för tillståndskänsliga operatorer för strömmande förfrågningar. Den stöder endast körning som en batchfråga.

Syntax

read_state_metadata(path)

Argument

Den här funktionen kräver namngivna parameteranrop för alternativnycklarna.

  • path: En STRING literal med sökvägen till platsen för den strömmande frågekontrollpunkten.

Returer

En tabell med tillståndsmetadata har följande schema. Alla kolumner är INTE NULL.

  • operatorId INT NOT NULL

    Ett heltals-ID för en tillståndskänslig strömningsoperatör.

  • operatorName STRING NOT NULL

    Namnet på den statliga strömningsoperatorn.

  • stateStoreName STRING NOT NULL

    Namnet på operatörens tillståndslager.

  • numPartitions INT NOT NULL

    Antal partitioner i tillståndslagring.

  • minBatchId BIGINT NOT NULL

    Det minsta batch-ID som är tillgängligt för frågestatus. Värdet kan vara ogiltigt om direktuppspelningsfrågan genomför en kontrollpunkt, eftersom det skulle leda till att rensningen körs.

  • maxBatchId BIGINT NOT NULL

    Det maximala batch-ID som är tillgängligt för frågetillstånd. Värdet kan vara ogiltigt om den strömmande frågan som tar kontrollpunkten körs, eftersom frågan kommer att bearbeta ytterligare batchar.

Exempel

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