system.predicate_statistics_log

​

الوصف

<clickhouse>
    <predicate_statistics_log>
        <database>system</database>
        <table>predicate_statistics_log</table>
        <partition_by>toYYYYMM(event_date)</partition_by>
        <flush_interval_milliseconds>7500</flush_interval_milliseconds>
    </predicate_statistics_log>
</clickhouse>

​

أنماط الصفوف

• صفوف التصفية، وتُصدَر لكل خطوة prewhere/تصفية في MergeTreeSelectProcessor. وتملأ الأعمدة 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، بمدخل واحد لكل مرحلة فهرسة (المفتاح الأساسي، والتقسيم، وفهارس التخطي). أما الأعمدة المرتبطة بالمسند فتكون فارغة.

​

أخذ العينات والعبء الإضافي

• 0 يعطّل الجمع.
• 1 يأخذ عيّنة من كل query.
• N > 1 يأخذ عيّنة من حوالي 1 / N من queries، استنادًا إلى قيمة hash لـ query_id.

​

الأعمدة

• hostname (LowCardinality(String)) — اسم المضيف للخادم الذي ينفّذ الاستعلام.
• clickhouse_version (LowCardinality(String)) — إصدار خادم ClickHouse الذي أنتج الصف.
• system_processor (LowCardinality(String)) — معمارية وحدة المعالجة المركزية لخادم ClickHouse الذي أنتج الصف.
• event_date (Date) — تاريخ الحدث.
• event_time (DateTime) — الطابع الزمني عند كتابة مُدخل السجل هذا.
• database (LowCardinality(String)) — اسم قاعدة بيانات الجدول الهدف.
• table (LowCardinality(String)) — اسم الجدول الهدف.
• query_id (String) — معرّف الاستعلام للرجوع إلى query_log.
• predicate_expression (String) — تعبير المسند الكامل الذي تتعامل معه خطوة prewhere/تصفية هذه (تفريغ ActionsDAG).
• input_rows (UInt64) — الصفوف التي تدخل إلى خطوة prewhere/تصفية هذه.
• passed_rows (UInt64) — الصفوف التي اجتازت خطوة prewhere/تصفية هذه.
• 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 (في صفوف الفهارس فقط).

​

مثال

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