在 ClickHouse Cloud 中查询此系统表中的数据分别保存在 ClickHouse Cloud 各节点的本地。因此,如需查看所有数据的完整情况,需要使用
clusterAllReplicas 函数。更多详情请参见此处。说明
MergeTree 表读取数据时收集的样本选择性统计信息。仅当 predicate_statistics_sample_rate 大于 0 时,才会填充该表。
可使用此表查看真实工作负载中用户谓词的选择性,以及经过主键或跳过索引过滤后还剩余多少粒度。这些数据可作为基于工作负载的索引和投影建议的输入。
行形态
system.predicate_statistics_log 中生成两类行:
- 过滤行:在
MergeTreeSelectProcessor中,每个 prewhere/过滤器步骤都会生成一行。它们会填充predicate_expression、input_rows、passed_rows、filter_selectivity,以及表示整个谓词的列total_input_rows、total_passed_rows、total_selectivity。与索引相关的列为空。 - 索引行:在
ReadFromMergeTree中,每个读取步骤都会生成一行。它们会填充index_names、index_types、total_granules、granules_after和index_selectivities数组,其中每个索引阶段对应一个条目 (主键、分区、跳过索引) 。与谓词相关的列为空。
query_id 和 table,因此在同时需要两者时可以将它们联接起来。
采样与开销
predicate_statistics_sample_rate 控制:
0禁用采集。1对每个查询都采样。N > 1对大约1 / N的查询进行采样,并按query_id计算哈希。
SYSTEM FLUSH LOGS。
列
hostname(LowCardinality(String)) — 执行该查询的服务器的主机名。event_date(Date) — 事件日期。event_time(DateTime) — 写入此日志条目时的时间戳。database(LowCardinality(String)) — 目标表所在数据库的名称。table(LowCardinality(String)) — 目标表的表名。query_id(String) — 用于关联回 query_log 的查询 ID。predicate_expression(String) — 此 prewhere/filter 步骤处理的完整过滤表达式 (ActionsDAG 转储) 。input_rows(UInt64) — 进入此 prewhere/filter 步骤的行数。passed_rows(UInt64) — 通过此 prewhere/filter 步骤后保留下来的行数。filter_selectivity(Float64) — 此步骤的选择性:passed_rows / input_rows。total_input_rows(UInt64) — 进入第一个 prewhere 步骤的行数 (即从粒度中读取的总行数) 。total_passed_rows(UInt64) — 经过所有 prewhere 步骤后保留下来的行数 (即传递给查询的行数) 。total_selectivity(Float64) — 整个谓词的选择性:total_passed_rows / total_input_rows。index_names(Array(LowCardinality(String))) — 应用的索引名称,例如 [‘PrimaryKey’, ‘idx_bf_status’] (仅索引行) 。index_types(Array(LowCardinality(String))) — 应用的索引类型:PrimaryKey、Skip、MinMax、Partition (仅索引行) 。total_granules(Array(UInt64)) — 进入各索引阶段的粒度数 (仅索引行) 。granules_after(Array(UInt64)) — 每个索引阶段后剩余的粒度数 (仅索引行) 。index_selectivities(Array(Float64)) — 各索引的选择性:granules_after / total_granules (仅索引行) 。