Share via

read_state_metadata-Tabellenwertfunktion

  • Artikel

Gilt für:check marked yes Databricks Runtime 14.3 und höher

Gibt eine Tabelle mit Zeilen zurück, die die Metadaten eines Streamingabfragestatus darstellen.

Eine Tabellenwertfunktion zum Lesen von Metadaten von zustandsbehafteten Operatoren für Streamingabfragen. Sie unterstützt nur die Ausführung als Batchabfrage.

Syntax

read_state_metadata(path)

Argumente

Diese Funktion erfordert einen Aufruf benannter Parameter für die Optionsschlüssel.

  • path: Ein STRING-Literal mit dem Pfad zum Speicherort des Prüfpunkts für die Streamingabfrage.

Gibt zurück

Eine Tabelle mit Statusmetadaten weist das folgende Schema auf. Alle Spalten sind NICHT NULL.

  • operatorId INT NOT NULL

    Eine ganzzahlige ID des zustandsbehafteten Streamingoperators.

  • operatorName STRING NOT NULL

    Name des zustandsbehafteten Streamingoperators.

  • stateStoreName STRING NOT NULL

    Name des Zustandsspeichers des Operators.

  • numPartitions INT NOT NULL

    Anzahl der Partitionen des Zustandsspeichers.

  • minBatchId BIGINT NOT NULL

    Die niedrigste Batch-ID, die für den Abfragezustand verfügbar ist. Der Wert kann ungültig sein, wenn die Streamingabfrage, die den Prüfpunkt nutzt, ausgeführt wird, da dadurch eine Bereinigung ausgeführt wird.

  • maxBatchId BIGINT NOT NULL

    Die höchste Batch-ID, die für den Abfragezustand verfügbar ist. Der Wert kann ungültig sein, wenn die Streamingabfrage, die den Prüfpunkt nutzt, ausgeführt wird, da die Abfrage weitere Batches committet.

Beispiele

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