read_state_metadata
-Tabellenwertfunktion
Gilt für: Databricks SQL 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
: EinSTRING
-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');