read_state_metadata
funkcja wartości tabeli
Dotyczy: Databricks SQL Databricks Runtime 14.3 i nowsze
Zwraca tabelę z wierszami reprezentującymi metadane stanu zapytania przesyłania strumieniowego.
Funkcja z wartością tabeli do odczytywania metadanych operatorów stanowych zapytań przesyłanych strumieniowo. Obsługuje tylko uruchamianie jako zapytanie wsadowe.
Składnia
read_state_metadata(path)
Argumenty
Ta funkcja wymaga wywołania nazwanego parametru dla kluczy opcji.
path
STRING
: literał ze ścieżką lokalizacji punktu kontrolnego zapytania przesyłania strumieniowego.
Zwraca
Tabela metadanych stanu ma następujący schemat. Wszystkie kolumny nie mają wartości NULL.
operatorId INT NOT NULL
Identyfikator liczb całkowitych operatora przesyłania strumieniowego stanowego.
operatorName STRING NOT NULL
Nazwa stanowego operatora przesyłania strumieniowego.
stateStoreName STRING NOT NULL
Nazwa magazynu stanów operatora.
numPartitions INT NOT NULL
Liczba partycji magazynu stanów.
minBatchId BIGINT NOT NULL
Minimalny identyfikator partii dostępny do wykonywania zapytań o stan. Wartość może być nieprawidłowa, jeśli zapytanie przesyłane strumieniowo biorące punkt kontrolny jest uruchomione, ponieważ spowoduje to uruchomienie oczyszczania.
maxBatchId BIGINT NOT NULL
Maksymalny identyfikator partii dostępny dla stanu wykonywania zapytań. Wartość może być nieprawidłowa, jeśli zapytanie przesyłane strumieniowo biorące punkt kontrolny jest uruchomione, ponieważ zapytanie zatwierdzi dalsze partie.
Przykłady
- Read state metadata from the checkpoint
> SELECT * FROM read_state_metadata('/checkpoint/path');