Freigeben über

read_statestore-Tabellenwertfunktion

  • Artikel

Gilt für: Häkchen ja Databricks SQL durch Häkchen mit „Ja“ markiert Databricks Runtime 14.3 und höher

Wichtig

Dieses Feature befindet sich in der Public Preview.

Eine Tabellenwertfunktion zum Lesen von Datensätzen aus dem Statusspeicher von Streamingabfragen. Die zurückgegebene Beziehung unterstützt nur die Ausführung als Batchabfrage.

Syntax

read_statestore ( path [, option_key => option_value ] [ ... ] )

Argumente

read_statestore erfordert einen benannten Parameteraufruf für seine optionalen Parameter.

  • path: Ein STRING literal-Wert. Der Pfad zum Speicherort des Prüfpunkts für die Streamingabfrage.
  • option_key: Der Name der zu konfigurierenden Option. Sie müssen Graviszeichen (`) für Optionen verwenden, die Punkte (.) enthalten.
  • option_value: Ein konstanter Ausdruck, auf den die Option festgelegt werden soll. Akzeptiert Literale und Skalarfunktionen.

Bei allen option_value wird die Groß- und Kleinschreibung nicht berücksichtigt.

option_key Typ Standard Beschreibung
batchId BIGINT neueste Batch-ID Stellt den Zielbatch dar, aus dem gelesen werden soll. Diese Option wird verwendet, wenn Benutzer*innen Zeitreisen durchführen möchten. Der Batch sollte committet, aber noch nicht bereinigt werden.
OperatorId BIGINT 0 Stellt den Zieloperator dar, aus dem gelesen werden soll. Diese Option wird verwendet, wenn die Abfrage mehrere zustandsbehaftete Operatoren verwendet.
storeName STRING 'DEFAULT' Stellt die Zielseite dar, aus der gelesen werden soll. Diese Option wird verwendet, wenn Benutzer*innen den Status aus der Stream-Stream-Verknüpfung lesen möchten.
joinSide STRING 'None' Stellt die Zielseite dar, aus der gelesen werden soll. Diese Option wird verwendet, wenn Benutzer*innen den Status aus der Stream-Stream-Verknüpfung lesen möchten. Einer der folgenden Werte: 'Left', 'Right', 'None'.

Gibt zurück

Die Funktion gibt ein Resultset mit den folgenden Spalten zurück.

Hinweis

Die geschachtelten Spalten für Schlüssel und Wert hängen stark vom Eingabeschema des zustandsbehafteten Operators und vom Typ des Operators ab.

Name Datentyp Nullable Standard BESCHREIBUNG
id STRUCT Nein Schlüsselzeile des zustandsbehafteten Operators, der im Zustandsprüfpunkt gespeichert ist.
value STRUCT Ja Wertzeile des zustandsbehafteten Operators, der im Zustandsprüfpunkt gespeichert ist.
partition_id INTEGER Nein Die Partition, die den Datensatz enthält.
shardId STRING Nein Ein eindeutiger Bezeichner für den Shard, aus dem die Daten gelesen wurden.
sequenceNumber BIGINT Nein Der eindeutige Bezeichner des Datensatzes innerhalb des Shards.
approximateArrivalTimestamp TIMESTAMP Nein Die ungefähre Zeit, zu der der Datensatz in den Datenstrom eingefügt wurde.

Beispiele

- Read from state
> SELECT * FROM read_statestore('/checkpoint/path');

– Read from state with storeName option
> SELECT * FROM read_statestore(
      '/checkpoint/path',
      operatorId => 0,
      batchId => 2,
      storeName => 'default'
  );

– Read from state with joinSide option

> SELECT * FROM read_statestore(
      '/checkpoint/path',
      joinSide => 'left'
  );