Dela via

read_state_metadata tablevärdefunktion

  • Artikel

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

Returnerar en table med rader som representerar metadata för ett frågetillstånd i stream.

En table-värdesfunktion för att läsa metadata från operatörer med tillstånd för strömmande frågeprocesser. 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 table med tillståndsmetadata har följande schema. Alla columns är INTE NULL.

  • operatorId INT NOT NULL

    Ett heltals-ID för den tillståndskänsliga strömningsoperatorn.

  • operatorName STRING NOT NULL

    Namnet på den tillståndskänsliga strömningsoperatorn.

  • stateStoreName STRING NOT NULL

    Namnet på operatorns tillståndslager.

  • numPartitions INT NOT NULL

    Antal partitioner i tillståndsarkivet.

  • minBatchId BIGINT NOT NULL

    Det minsta batch-ID som är tillgängligt för frågetillstånd. Värdet kan vara ogiltigt om den direktuppspelningsfråga som tar kontrollpunkten körs, eftersom rensningen skulle köras.

  • 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åga som tar kontrollpunkten körs, eftersom frågan kommer att checka in ytterligare batchar.

Exempel

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