From bcac24bc580fa600f23425c623e84062deccb887 Mon Sep 17 00:00:00 2001 From: Nikolaos Karaolidis Date: Thu, 25 Jan 2024 15:15:40 +0000 Subject: [PATCH] Add bloom filter index on news Signed-off-by: Nikolaos Karaolidis --- src/threads/data/backfill.rs | 4 ++-- support/clickhouse/docker-entrypoint-initdb.d/0000_init.sql | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/threads/data/backfill.rs b/src/threads/data/backfill.rs index ff7fae0..ae5ecb6 100644 --- a/src/threads/data/backfill.rs +++ b/src/threads/data/backfill.rs @@ -112,7 +112,7 @@ async fn handle_backfill_message( if !job.is_finished() { job.abort(); } - job.await.unwrap_err(); + let _ = job.await; } let app_config = app_config.clone(); @@ -158,7 +158,7 @@ async fn handle_backfill_message( if !job.is_finished() { job.abort(); } - job.await.unwrap_err(); + let _ = job.await; } } diff --git a/support/clickhouse/docker-entrypoint-initdb.d/0000_init.sql b/support/clickhouse/docker-entrypoint-initdb.d/0000_init.sql index f051581..dc475d8 100644 --- a/support/clickhouse/docker-entrypoint-initdb.d/0000_init.sql +++ b/support/clickhouse/docker-entrypoint-initdb.d/0000_init.sql @@ -50,6 +50,7 @@ CREATE TABLE IF NOT EXISTS qrust.news ( source Nullable(String), summary Nullable(String), url Nullable(String), + INDEX index_symbols symbols TYPE bloom_filter() ) ENGINE = ReplacingMergeTree() PARTITION BY toYYYYMM(time_created)