Перейти к содержимому
Последнее обновление

table_stream_consumption

Обзор​

Содержит смещение потребления, величину отставания и время последнего потребления каждого Table Stream для каждой партиции его базовой таблицы. Каждая строка соответствует одной единице потребления (партиции базовой таблицы) одного Stream. Подробнее об использовании см. в разделе Расширенные возможности Table Stream.

База данных​

information_schema

Информация о таблице​

СтолбецТипОписание
DB_NAMEvarchar(64)База данных, к которой относится Stream
STREAM_NAMEvarchar(64)Имя Stream
STREAM_IDbigintИдентификатор Stream
UNITvarchar(64)Единица потребления, то есть имя партиции базовой таблицы. Таблица без явно заданных партиций содержит единственную партицию с именем таблицы
CONSUMPTION_STATUSvarchar(64)Метка времени фиксации (TSO), до которой были потреблены данные партиции; N/A означает, что данные партиции ещё ни разу не потреблялись
LAGvarchar(64)Разность между последним зафиксированным TSO партиции и TSO, до которого были потреблены данные; 0 означает отсутствие отставания, N/A означает, что в партиции есть данные, но они ещё ни разу не потреблялись. Младшие 18 бит TSO представляют собой логический счётчик, поэтому значение LAG, делённое на 262144, приблизительно соответствует отставанию в миллисекундах
LAST_CONSUMPTION_TIMEbigintВремя последнего потребления данных партиции (метка времени в миллисекундах); -1 означает, что данные ещё ни разу не потреблялись

Примеры​

SELECT UNIT, CONSUMPTION_STATUS, LAG, LAST_CONSUMPTION_TIME
FROM information_schema.table_stream_consumption
WHERE DB_NAME = 'demo' AND STREAM_NAME = 'orders_stream'
ORDER BY UNIT;
+-----------+--------------------+-----------+-----------------------+
| UNIT      | CONSUMPTION_STATUS | LAG       | LAST_CONSUMPTION_TIME |
+-----------+--------------------+-----------+-----------------------+
| p20260913 | 469041123123200000 | 0         |         1789267206000 |
| p20260914 | 469067681628160003 | 262144000 |         1789351206000 |
| p20260915 | N/A                | 0         |                    -1 |
+-----------+--------------------+-----------+-----------------------+
Report issue