描述
包含有关位于队列中、等待发送到各个分片的本地文件的信息。这些本地文件包含新的 parts,这些 parts 是在以异步模式向 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: