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');

Связанные статьи

• CREATE STREAMING TABLE
• read_kafka Функция с табличным значением