Описание
Содержит информацию о локальных файлах, находящихся в очереди на отправку в сегменты. Эти локальные файлы содержат новые части, которые создаются при вставке новых данных в таблицу Distributed в асинхронном режиме.
Столбцы
database(String) — Имя базы данных.table(String) — Имя таблицы.data_path(String) — Путь к папке с локальными файлами.is_blocked(UInt8) — Флаг, указывающий, заблокирована ли отправка локальных файлов на сервер.error_count(UInt64) — Количество ошибок.data_files(UInt64) — Количество локальных файлов в папке.data_compressed_bytes(UInt64) — Размер сжатых данных в локальных файлах в байтах.broken_data_files(UInt64) — Количество файлов, помеченных как повреждённые из-за ошибки.broken_data_compressed_bytes(UInt64) — Размер сжатых данных в повреждённых файлах в байтах.last_exception(String) — Текст последней возникшей ошибки (если она была).last_exception_time(DateTime) — Время возникновения последнего исключения.
Пример
SELECT * FROM system.distribution_queue LIMIT 1 FORMAT Vertical;Row 1:
──────
database: default
table: dist
data_path: ./store/268/268bc070-3aad-4b1a-9cf2-4987580161af/default@127%2E0%2E0%2E2:9000/
is_blocked: 1
error_count: 0
data_files: 1
data_compressed_bytes: 499
last_exception: