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

Функция с табличным значением read_state_metadata

  • Статья

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

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

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

Синтаксис

read_state_metadata(path)

Аргументы

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

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

Возвраты

Таблица метаданных состояния имеет следующую схему. Все столбцы имеют значение NOT 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');