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

read_state_metadata таблично-значная функция

Область применения:отмечено Databricks SQL отмечено Databricks Runtime 14.3 и выше

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

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

Синтаксис

read_state_metadata(path)

Аргументы

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

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

Возвраты

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