Udostępnij za pośrednictwem


read_state_metadata funkcja wartości tabeli

Dotyczy: zaznacz pole wyboru oznaczone jako tak Databricks SQL zaznacz pole wyboru oznaczone jako tak 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.

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