Skip to content

Commit 435aec1

Browse files
authored
chore: avoid bloom filter clone (#19098)
1 parent 3d026be commit 435aec1

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/query/catalog/src/runtime_filter_info.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ use databend_common_expression::Expr;
2525

2626
use crate::sbbf::Sbbf;
2727

28-
pub type RuntimeBloomFilter = Sbbf;
28+
pub type RuntimeBloomFilter = Arc<Sbbf>;
2929

3030
#[derive(Clone, Default)]
3131
pub struct RuntimeFilterInfo {

src/query/service/src/pipelines/processors/transforms/hash_join/runtime_filter/convert.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -280,7 +280,7 @@ async fn build_bloom_filter(
280280
filter.insert_hash_batch(&bloom);
281281
return Ok(RuntimeFilterBloom {
282282
column_name,
283-
filter,
283+
filter: Arc::new(filter),
284284
});
285285
}
286286

@@ -297,7 +297,7 @@ async fn build_bloom_filter(
297297

298298
Ok(RuntimeFilterBloom {
299299
column_name,
300-
filter,
300+
filter: Arc::new(filter),
301301
})
302302
}
303303

0 commit comments

Comments
 (0)