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: 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');

Verwandte Artikel

• CREATE STREAMING TABLE
• read_kafkaTabellenwertfunktion