system.predicate_statistics_log

Contient des statistiques de sélectivité échantillonnées collectées lors de la lecture de tables MergeTree. La table n'est renseignée que lorsque predicate_statistics_sample_rate est supérieur à 0.

Utilisez cette table pour examiner le degré de sélectivité des prédicats utilisateur dans des charges de travail réelles, ainsi que le nombre de granules restant après le filtrage par clé primaire ou index de saut. Ces données sont destinées à alimenter des recommandations d'index et de projections fondées sur les charges de travail.

Une même requête peut produire deux types de lignes dans system.predicate_statistics_log :

• Lignes de filtre, émises à chaque étape prewhere/filter dans MergeTreeSelectProcessor. Elles alimentent predicate_expression, input_rows, passed_rows, filter_selectivity, ainsi que les colonnes du prédicat complet total_input_rows, total_passed_rows, total_selectivity. Les colonnes liées aux index sont vides.
• Lignes d’index, émises à chaque étape de lecture dans ReadFromMergeTree. Elles alimentent les tableaux index_names, index_types, total_granules, granules_after et index_selectivities, avec une entrée par étape d’index (clé primaire, partition, skip indexes). Les colonnes liées aux prédicats sont vides.

Les lignes de filtre et les lignes d’index d’une même requête partagent le même query_id et la même table, et peuvent donc être jointes lorsque les deux sont nécessaires.

L'échantillonnage est contrôlé par predicate_statistics_sample_rate :

• 0 désactive la collecte.
• 1 échantillonne chaque requête.
• N > 1 échantillonne environ 1 / N des requêtes, selon un hachage de query_id.

Des valeurs plus faibles produisent davantage de données, mais augmentent la charge CPU sur le chemin de lecture ainsi que le nombre d'écritures dans le journal système. Après avoir activé ce paramètre, utilisez SYSTEM FLUSH LOGS si vous avez besoin que les lignes apparaissent immédiatement.

• hostname (LowCardinality(String)) — Nom d’hôte du serveur qui exécute la requête.
• event_date (Date) — Date de l’événement.
• event_time (DateTime) — Horodatage de l’écriture de cette entrée de journal.
• database (LowCardinality(String)) — Nom de la base de données de la table cible.
• table (LowCardinality(String)) — Nom de la table cible.
• query_id (String) — ID de requête permettant de faire le lien avec query_log.
• predicate_expression (String) — Expression de filtre complète prise en charge par cette étape prewhere/filter (dump ActionsDAG).
• input_rows (UInt64) — Lignes entrant dans cette étape prewhere/filter.
• passed_rows (UInt64) — Lignes conservées après cette étape prewhere/filter.
• filter_selectivity (Float64) — Sélectivité de cette étape : passed_rows / input_rows.
• total_input_rows (UInt64) — Lignes entrant dans la première étape prewhere (nombre total de lignes lues à partir des granules).
• total_passed_rows (UInt64) — Lignes conservées après toutes les étapes prewhere (lignes transmises à la requête).
• total_selectivity (Float64) — Sélectivité de l’ensemble du prédicat : total_passed_rows / total_input_rows.
• index_names (Array(LowCardinality(String))) — Noms des index appliqués, par ex. ['PrimaryKey', 'idx_bf_status'] (lignes d’index uniquement).
• index_types (Array(LowCardinality(String))) — Types d’index appliqués : PrimaryKey, Skip, MinMax, Partition (lignes d’index uniquement).
• total_granules (Array(UInt64)) — Granules à l’entrée de chaque étape d’index (lignes d’index uniquement).
• granules_after (Array(UInt64)) — Granules restants après chaque étape d’index (lignes d’index uniquement).
• index_selectivities (Array(Float64)) — Sélectivité par index : granules_after / total_granules (lignes d’index uniquement).

SET predicate_statistics_sample_rate = 1;

SELECT *
FROM hits
WHERE URL LIKE '%/product/%' AND EventDate >= today() - 7
FORMAT Null;

SYSTEM FLUSH LOGS predicate_statistics_log;

SELECT
    query_id,
    predicate_expression,
    round(filter_selectivity, 3) AS step_selectivity,
    round(total_selectivity, 3) AS query_selectivity,
    index_names,
    index_selectivities
FROM system.predicate_statistics_log
WHERE table = 'hits'
ORDER BY event_time DESC
LIMIT 10;

• predicate_statistics_sample_rate
• system.query_log