Поделиться через

функция read_state_metadatatable-valued

  • Статья

Область применения:флажок Databricks SQL флажок Databricks Runtime 14.3 и более поздних версий

Возвращает table со строками, представляющими метаданные состояния потокового запроса.

Функция со значением table для чтения метаданных операторов потокового запроса с отслеживанием состояния. Он поддерживает выполнение только в виде пакетного запроса.

Синтаксис

read_state_metadata(path)

Аргументы

Для этой функции требуется вызов именованного параметра для ключей параметров.

  • path STRING: литерал с путем расположения контрольной точки потокового запроса.

Возвраты

table метаданных состояния имеет следующие schema. Все columns не содержат NULL.

  • operatorId INT NOT NULL

    Целочисленный идентификатор оператора потоковой передачи с отслеживанием состояния.

  • operatorName STRING NOT NULL

    Имя оператора потоковой передачи с отслеживанием состояния.

  • stateStoreName STRING NOT NULL

    Имя хранилища состояний оператора.

  • numPartitions INT NOT NULL

    Количество секций хранилища состояний.

  • minBatchId BIGINT NOT NULL

    Минимальный идентификатор пакета, доступный для запроса состояния. Значение может быть недопустимым, если потоковый запрос, принимающие контрольную точку, запущен, так как это приведет к очистке.

  • maxBatchId BIGINT NOT NULL

    Максимальный идентификатор пакета, доступный для запроса состояния. Значение может быть недопустимым, если потоковый запрос, принимающие контрольную точку, выполняется, так как запрос зафиксирует дополнительные пакеты.

Примеры

- Read state metadata from the checkpoint
> SELECT * FROM read_state_metadata('/checkpoint/path');