Udostępnij za pośrednictwem

read_statestore funkcja wartości tabeli

  • Artykuł

Dotyczy: zaznacz pole wyboru oznaczone jako tak Databricks SQL zaznacz pole wyboru oznaczone jako tak Databricks Runtime 14.3 i nowsze

Ważne

Ta funkcja jest dostępna w publicznej wersji zapoznawczej.

Funkcja tabeli z wartością do odczytywania rekordów z magazynu stanów zapytań przesyłanych strumieniowo. Zwrócona relacja obsługuje tylko uruchamianie jako zapytanie wsadowe.

Składnia

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

Argumenty

read_statestore wymaga wywołania nazwanego parametru dla parametrów opcjonalnych.

  • path: A STRING literal. Ścieżka lokalizacji punktu kontrolnego zapytania przesyłania strumieniowego.
  • option_key: nazwa opcji do skonfigurowania. Należy użyć backticks (') dla opcji zawierających kropki (.).
  • option_value: wyrażenie stałe, aby ustawić opcję na . Akceptuje literały i funkcje skalarne.

Wszystkie option_values są bez uwzględniania wielkości liter.

option_key Typ Domyślny opis
batchId BIGINT najnowszy identyfikator partii Reprezentuje partię docelową do odczytu. Ta opcja jest używana, gdy użytkownicy chcą wykonać podróż czasową. Partia powinna zostać zatwierdzona, ale nie została jeszcze wyczyszczona.
OperatorId BIGINT 0 Reprezentuje operator docelowy do odczytu. Ta opcja jest używana, gdy zapytanie używa wielu operatorów stanowych.
storeName STRING 'DEFAULT' Reprezentuje stronę docelową do odczytania. Ta opcja jest używana, gdy użytkownicy chcą odczytać stan ze sprzężenia strumienia strumienia.
joinSide STRING 'None' Reprezentuje stronę docelową do odczytania. Ta opcja jest używana, gdy użytkownicy chcą odczytać stan ze sprzężenia strumienia strumienia. Jeden z: 'Left', 'Right', 'None'.

Zwraca

Funkcja zwraca zestaw wyników z następującymi kolumnami.

Uwaga

Kolumny zagnieżdżone dla klucza i wartości w dużym stopniu zależą od schematu wejściowego operatora stanowego i typu operatora.

Nazwisko Typ danych Dopuszczający wartość null Standardowa opis
id STRUCT Nie. Klucz wiersza operatora stanowego przechowywanego w punkcie kontrolnym stanu.
value STRUCT Tak Wiersz wartości operatora stanowego przechowywany w punkcie kontrolnym stanu.
partition_id INTEGER Nie. Partycja zawierająca rekord.
shardId STRING Nie. Unikatowy identyfikator fragmentu, z którego odczytywano dane.
sequenceNumber BIGINT Nie. Unikatowy identyfikator rekordu w ramach jego fragmentu.
approximateArrivalTimestamp TIMESTAMP Nie. Przybliżony czas wstawienia rekordu do strumienia.

Przykłady

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